MergeMeasurementsTask#

class lsst.pipe.tasks.mergeMeasurements.MergeMeasurementsTask(schema=None, initInputs=None, **kwargs)#

Bases: PipelineTask

Merge measurements from multiple bands.

Combines consistent (i.e. with the same peaks and footprints) catalogs of sources from multiple filter bands to construct a unified catalog that is suitable for driving forced photometry. Every source is required to have centroid, shape and flux measurements in each band.

MergeMeasurementsTask is meant to be run after deblending & measuring sources in every band. The purpose of the task is to generate a catalog of sources suitable for driving forced photometry in coadds and individual exposures.

Parameters#

schemalsst.afw.table.Schema, optional: The schema of the detection catalogs used as input to this task.
initInputsdict, optional: Dictionary that can contain a key inputSchema containing the input schema. If present will override the value of schema.
**kwargs: Additional keyword arguments.

Attributes Summary

`inputDataset`
`outputDataset`

Methods Summary

`run`(catalogs)	Merge measurement catalogs to create a single reference catalog for forced photometry.
`runQuantum`(butlerQC, inputRefs, outputRefs)	Do butler IO and transform to provide in memory objects for tasks `run` method.

Attributes Documentation

inputDataset = 'meas'#

outputDataset = 'ref'#

Methods Documentation

run(catalogs)#

Merge measurement catalogs to create a single reference catalog for forced photometry.

Parameters#

catalogslsst.afw.table.SourceCatalog: Catalogs to be merged.

Raises#

ValueError: Raised if no catalog records were found; if there is no valid reference for the input record ID; or if there is a mismatch between catalog sizes.

Notes#

For parent sources, we choose the first band in config.priorityList for which the merge_footprint flag for that band is is True.

For child sources, the logic is the same, except that we use the merge_peak flags.

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.