hipscatalog_gen.mag_global.pipeline.prepare_mag_global

prepare_mag_global(ddf, cfg, diag_ctx, log_fn, params, persist_ddfs=False, avoid_computes=True)

Restrict to the configured magnitude window using pre-computed params.

Parameters:

• ddf (Any) – Dask-like collection with __mag__ already attached.

• cfg (Any) – Parsed configuration object.

• diag_ctx – Diagnostics context factory.

• log_fn – Logging callback.

• params (MagGlobalParams) – Resolved magnitude parameters.

• persist_ddfs (bool) – Whether to persist the filtered DDF.

• avoid_computes (bool) – Whether to avoid explicit compute() calls when possible.

Returns:

Dask-like collection filtered to the magnitude window.