TransformForcedSourceTableTask

class lsst.pipe.tasks.postprocess.TransformForcedSourceTableTask(*args, **kwargs)

Bases: TransformCatalogBaseTask

Transform/standardize a ForcedSource catalog

Transforms each wide, per-detector forcedSource DataFrame per the specification file (per-camera defaults found in ForcedSource.yaml). All epochs that overlap the patch are aggregated into one per-patch narrow-DataFrame file.

No de-duplication of rows is performed. Duplicate resolutions flags are pulled in from the referenceCatalog: detect_isPrimary, detect_isTractInner,`detect_isPatchInner`, so that user may de-duplicate for analysis or compare duplicates for QA.

The resulting table includes multiple bands. Epochs (MJDs) and other useful per-visit rows can be retreived by joining with the CcdVisitTable on ccdVisitId.

Methods Summary

run(inputCatalogs, referenceCatalog[, ...])	Do postprocessing calculations
runQuantum(butlerQC, inputRefs, outputRefs)	Do butler IO and transform to provide in memory objects for tasks run method.

Methods Documentation

run(inputCatalogs, referenceCatalog, funcs=None, dataId=None, band=None)

Do postprocessing calculations

Takes a DeferredDatasetHandle or InMemoryDatasetHandle or DataFrame object and dataId, returns a dataframe with results of postprocessing calculations.

Parameters

handlesDeferredDatasetHandle or

InMemoryDatasetHandle or DataFrame, or list of these.

DataFrames from which calculations are done.

funcsFunctor

Functors to apply to the table’s columns

dataIddict, optional

Used to add a patchId column to the output dataframe.

bandstr, optional

Filter band that is being processed.

Returns

resultlsst.pipe.base.Struct

Result struct, with a single outputCatalog attribute holding the transformed 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.