hipscatalog_gen.pipeline.structure.PipelineContext

class PipelineContext(cfg, out_dir, report_dir, log_fn, diag_ctx, persist_ddfs, avoid_computes, selection_mode, log_ctx=None, ddf=None, RA_NAME=None, DEC_NAME=None, keep_cols=None, is_hats=False, paths=None, input_total=None, remainder_ddf=None, densmaps=<factory>, total_written=None, selection_params=None, telemetry=<factory>)

Bases: object

Shared state passed between pipeline stages.

Parameters:

• cfg (Config)

• out_dir (Path)

• report_dir (Path)

• log_fn (Callable[[...], None])

• diag_ctx (Callable[[str], ContextManager[Any]])

• persist_ddfs (bool)

• avoid_computes (bool)

• selection_mode (str)

• log_ctx (Any | None)

• ddf (Any | None)

• RA_NAME (str | None)

• DEC_NAME (str | None)

• keep_cols (List[str] | None)

• is_hats (bool)

• paths (List[str] | None)

• input_total (int | None)

• remainder_ddf (Any | None)

• densmaps (Dict[int, ndarray])

• total_written (int | None)

• selection_params (Any | None)

• telemetry (Dict[str, Any])

__init__(cfg, out_dir, report_dir, log_fn, diag_ctx, persist_ddfs, avoid_computes, selection_mode, log_ctx=None, ddf=None, RA_NAME=None, DEC_NAME=None, keep_cols=None, is_hats=False, paths=None, input_total=None, remainder_ddf=None, densmaps=<factory>, total_written=None, selection_params=None, telemetry=<factory>)

Parameters:

• cfg (Config)

• out_dir (Path)

• report_dir (Path)

• log_fn (Callable[[...], None])

• diag_ctx (Callable[[str], ContextManager[Any]])

• persist_ddfs (bool)

• avoid_computes (bool)

• selection_mode (str)

• log_ctx (Any | None)

• ddf (Any | None)

• RA_NAME (str | None)

• DEC_NAME (str | None)

• keep_cols (List[str] | None)

• is_hats (bool)

• paths (List[str] | None)

• input_total (int | None)

• remainder_ddf (Any | None)

• densmaps (Dict[int, ndarray])

• total_written (int | None)

• selection_params (Any | None)

• telemetry (Dict[str, Any])

Return type:

None

Methods

__init__(cfg, out_dir, report_dir, log_fn, ...)
with_updates(**kwargs)	Return a new context with updated fields.

Attributes

cfg
out_dir
report_dir
log_fn
diag_ctx
persist_ddfs
avoid_computes
selection_mode
log_ctx
ddf
RA_NAME
DEC_NAME
keep_cols
is_hats
paths
input_total
remainder_ddf
densmaps
total_written
selection_params
telemetry

cfg: Config

out_dir: Path

report_dir: Path

log_fn: Callable[[...], None]

diag_ctx: Callable[[str], ContextManager[Any]]

persist_ddfs: bool

avoid_computes: bool

selection_mode: str

log_ctx: Any | None

ddf: Any | None

RA_NAME: str | None

DEC_NAME: str | None

keep_cols: List[str] | None

is_hats: bool

paths: List[str] | None

input_total: int | None

remainder_ddf: Any | None

densmaps: Dict[int, ndarray]

total_written: int | None

selection_params: Any | None

telemetry: Dict[str, Any]

with_updates(**kwargs)

Return a new context with updated fields.

Parameters:

kwargs (Any)

Return type:

PipelineContext