WriteSourceTableTask

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

Bases: PipelineTask

Write source table to DataFrame Parquet format.

Methods Summary

run(catalog, visit, detector, **kwargs)	Convert src catalog to an Astropy table.
runQuantum(butlerQC, inputRefs, outputRefs)	Do butler IO and transform to provide in memory objects for tasks run method.

Methods Documentation

run(catalog, visit, detector, **kwargs)

Convert src catalog to an Astropy table.

Parameters

catalog: afwTable.SourceCatalog

catalog to be converted

visit, detector: int

Visit and detector ids to be added as columns.

**kwargs

Additional keyword arguments are ignored as a convenience for subclasses that pass the same arguments to several different methods.

Returns

resultStruct

table

astropy.table.Table version of the input catalog

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.