WriteObjectTableTask

class lsst.pipe.tasks.postprocess.WriteObjectTableTask(*, config: PipelineTaskConfig | None = None, log: logging.Logger | LsstLogAdapter | None = None, initInputs: dict[str, Any] | None = None, **kwargs: Any)

Bases: PipelineTask

Write filter-merged object tables as a DataFrame in parquet format.

Attributes Summary

outputDataset

Methods Summary

run(catalogs, tract, patch)	Merge multiple catalogs.
runQuantum(butlerQC, inputRefs, outputRefs)	Do butler IO and transform to provide in memory objects for tasks run method.

Attributes Documentation

outputDataset = 'obj'

Methods Documentation

run(catalogs, tract, patch)

Merge multiple catalogs.

Parameters

catalogsdict

Mapping from filter names to dict of catalogs.

tractint

tractId to use for the tractId column.

patchstr

patchId to use for the patchId column.

Returns

catalogpandas.DataFrame

Merged dataframe.

Raises

ValueError

Raised if any of the catalogs is of an unsupported type.

runQuantum(butlerQC, inputRefs, outputRefs)

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.