AdjustQuantumHelper¶
- class lsst.pipe.base.AdjustQuantumHelper(inputs: NamedKeyMapping[DatasetType, Sequence[DatasetRef]], outputs: NamedKeyMapping[DatasetType, Sequence[DatasetRef]], inputs_adjusted: bool = False, outputs_adjusted: bool = False)¶
Bases:
object
Helper class for calling
PipelineTaskConnections.adjustQuantum
.This class holds
input
andoutput
mappings in the form used byQuantum
and execution harness code, i.e. withDatasetType
keys, translating them to and from the connection-oriented mappings used insidePipelineTaskConnections
.Attributes Summary
Whether any inputs were removed in the last call to
adjust_in_place
.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 updateself
with its results.Attributes Documentation
- inputs_adjusted: bool = False¶
Whether any inputs were removed in the last call to
adjust_in_place
.
- outputs_adjusted: bool = False¶
Whether any outputs were removed in the last call to
adjust_in_place
.
Methods Documentation
- adjust_in_place(connections: PipelineTaskConnections, label: str, data_id: DataCoordinate) None ¶
Call
adjustQuantum
and updateself
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).
- connections