QuantumGraphTaskNodes¶
-
class
lsst.pipe.base.
QuantumGraphTaskNodes
(taskDef: lsst.pipe.base.pipeline.TaskDef, quanta: List[lsst.daf.butler.core.quantum.Quantum], initInputs: Mapping[lsst.daf.butler.core.datasets.type.DatasetType, lsst.daf.butler.core.datasets.ref.DatasetRef], initOutputs: Mapping[lsst.daf.butler.core.datasets.type.DatasetType, lsst.daf.butler.core.datasets.ref.DatasetRef])¶ Bases:
object
QuantumGraphTaskNodes represents a bunch of nodes in an quantum graph corresponding to a single task.
The node in quantum graph is represented by the
PipelineTask
and a singleQuantum
instance. One possible representation of the graph is just a list of nodes without edges (edges can be deduced from nodes’ quantum inputs and outputs if needed). That representation can be reduced to the list of PipelineTasks (or their corresponding TaskDefs) and the corresponding list of Quanta. This class is used in this reduced representation for a single task, and fullQuantumGraph
is a sequence of tinstances of this class for one or more tasks.Different frameworks may use different graph representation, this representation was based mostly on requirements of command-line executor which does not need explicit edges information.