ConsolidateInjectedCatalogsTask

class lsst.source.injection.ConsolidateInjectedCatalogsTask(*, config: PipelineTaskConfig | None = None, log: logging.Logger | LsstLogAdapter | None = None, initInputs: dict[str, Any] | None = None, **kwargs: Any)

Bases: PipelineTask

Class for combining all tables in a collection of input catalogs into one table.

Methods Summary

run(catalog_dict, skymap, tract)	Consolidate all tables in catalog_dict into one table.
runQuantum(butlerQC, input_refs, output_refs)	Do butler IO and transform to provide in memory objects for tasks run method.

Methods Documentation

run(catalog_dict: dict, skymap: BaseSkyMap, tract: int) → Table

Consolidate all tables in catalog_dict into one table.

catalog_dict: dict

A dictionary with photometric bands for keys and astropy tables for items.

skymap: lsst.skymap.BaseSkyMap

A base skymap.

tract: int

The tract where sources have been injected.

Returns

output_structlsst.pipe.base.Struct

contains :

multiband_catalog: astropy.table.Table

A single table containing all information of the separate tables in catalog_dict

runQuantum(butlerQC, input_refs, output_refs)

Do butler IO and transform to provide in memory objects for tasks run method.

Parameters

butlerQCQuantumContext

A butler which is specialized to operate in the context of a lsst.daf.butler.Quantum.

inputRefsInputQuantizedConnection

Datastructure whose attribute names are the names that identify connections defined in corresponding PipelineTaskConnections class. The values of these attributes are the lsst.daf.butler.DatasetRef objects associated with the defined input/prerequisite connections.

outputRefsOutputQuantizedConnection

Datastructure whose attribute names are the names that identify connections defined in corresponding PipelineTaskConnections class. The values of these attributes are the lsst.daf.butler.DatasetRef objects associated with the defined output connections.