hipscatalog_gen.pipeline.common.build_and_prepare_input

build_and_prepare_input(cfg, diag_ctx, log_fn, persist_ddfs)

Load inputs, validate RA/DEC, repartition, and persist when needed.

Parameters:

• cfg (Any) – Parsed configuration object.

• diag_ctx – Diagnostics context factory (label -> context manager).

• log_fn – Logging callback.

• persist_ddfs (bool) – Whether to persist the input collection in memory.

Returns:

• ddf: Dask-like collection ready for downstream stages.

• RA_NAME / DEC_NAME: Resolved column names for coordinates.

• keep_cols: Ordered list of columns to keep.

• is_hats: True when the input is an LSDB/HATS catalog.

• paths: List of resolved input paths.

Return type:

Tuple containing (ddf, RA_NAME, DEC_NAME, keep_cols, is_hats, paths) where