SourceObjectTableAnalysisTask

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

Bases: AnalysisPipelineTask

Methods Summary

applyAstrometricCorrections(isolatedSources, ...)	Shift source positions to match the epoch of the reference catalog objects.
callback(inputs, dataId)	Callback function to be used with reconstructor.
prepareAssociatedSources(visit, data, ...)	Match isolated sources with reference objects and shift the sources to the object epochs if self.config.applyAstrometricCorrections is True.
runQuantum(butlerQC, inputRefs, outputRefs)	Override default runQuantum to load the minimal columns necessary to complete the action.

Methods Documentation

applyAstrometricCorrections(isolatedSources, astrometricCorrectionCatalog, visitTable, visit, refEpochs)

Shift source positions to match the epoch of the reference catalog objects.

Parameters

isolatedSourcesastropy.table.Table

Catalog of sources which will be modified in place with the astrometric corrections.

astrometricCorrectionCatalogastropy.table.Table

Catalog with proper motion and parallax information.

visitTablepd.DataFrame

Catalog containing the epoch for the visit corresponding to the isolatedSources.

visitint

Identifier of the isolatedSources’ visit.

callback(inputs, dataId)

Callback function to be used with reconstructor.

prepareAssociatedSources(visit, data, associatedSourceRefs, associatedSourceIdRefs, refCats, visitTable, astrometricCorrectionCatalog)

Match isolated sources with reference objects and shift the sources to the object epochs if self.config.applyAstrometricCorrections is True.

Parameters

visitint

Identifier of the visit corresponding to the data.

dataastropy.table.Table

Catalog of sources to be associated.

associatedSourceRefslist [DeferredDatasetHandle]

Handle for the catalogs of isolated sources. There will be multiple if the visit overlaps with multiple tracts.

refCatslist [pd.DataFrame]

Catalog of objects with which the sources will be compared.

visitTablepd.DataFrame

Catalog containing the epoch for the visit corresponding to the isolatedSources.

astrometricCorrectionCatalogastropy.table.Table

Catalog with proper motion and parallax information.

runQuantum(butlerQC, inputRefs, outputRefs)

Override default runQuantum to load the minimal columns necessary to complete the action.

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.