AdjustQuantumHelper

class lsst.pipe.base.AdjustQuantumHelper(inputs: lsst.daf.butler.core.named.NamedKeyMapping[lsst.daf.butler.core.datasets.type.DatasetType, typing.List[lsst.daf.butler.core.datasets.ref.DatasetRef]][lsst.daf.butler.core.datasets.type.DatasetType, List[lsst.daf.butler.core.datasets.ref.DatasetRef]], outputs: lsst.daf.butler.core.named.NamedKeyMapping[lsst.daf.butler.core.datasets.type.DatasetType, typing.List[lsst.daf.butler.core.datasets.ref.DatasetRef]][lsst.daf.butler.core.datasets.type.DatasetType, List[lsst.daf.butler.core.datasets.ref.DatasetRef]], inputs_adjusted: bool = False, outputs_adjusted: bool = False)

Bases: object

Helper class for calling PipelineTaskConnections.adjustQuantum.

This class holds input and output mappings in the form used by Quantum and execution harness code, i.e. with DatasetType keys, translating them to and from the connection-oriented mappings used inside PipelineTaskConnections.

Attributes Summary

inputs_adjusted	Whether any inputs were removed in the last call to adjust_in_place.
outputs_adjusted	Whether any outputs were removed in the last call to adjust_in_place.

Methods Summary

adjust_in_place(connections, label, data_id)

Call adjustQuantum and update self with its results.

Attributes Documentation

inputs_adjusted = False

Whether any inputs were removed in the last call to adjust_in_place.

outputs_adjusted = False

Whether any outputs were removed in the last call to adjust_in_place.

Methods Documentation

adjust_in_place(connections: lsst.pipe.base.connections.PipelineTaskConnections, label: str, data_id: lsst.daf.butler.core.dimensions._coordinate.DataCoordinate) → None

Call adjustQuantum and update self with its results.

Parameters:

connections : PipelineTaskConnections

Instance on which to call adjustQuantum.

label : str

Label for this task in the pipeline (should be used in all diagnostic messages).

data_id : lsst.daf.butler.DataCoordinate

Data ID for this quantum in the pipeline (should be used in all diagnostic messages).