QuantumNode¶

class lsst.pipe.base.QuantumNode(quantum: Quantum, taskDef: TaskDef, nodeId: UUID)¶

Class representing a node in the quantum graph.

The quantum attribute represents the data that is to be processed at this node.

Attributes Summary

`nodeId`	The unique position of the node within the graph assigned at graph creation.
`quantum`	The unit of data that is to be processed by this graph node
`taskDef`	Definition of the task that will process the `Quantum` associated with this node.
`task_node`	Return the node object that represents this task in a pipeline graph.

Methods Summary

`from_simple`(simple, taskDefMap, universe)
`to_simple`([accumulator])

Attributes Documentation

nodeId: UUID¶: The unique position of the node within the graph assigned at graph creation.

quantum: Quantum¶: The unit of data that is to be processed by this graph node

taskDef: TaskDef¶: Definition of the task that will process the Quantum associated with this node.

task_node¶: Return the node object that represents this task in a pipeline graph.

Methods Documentation

classmethod from_simple(simple: SerializedQuantumNode, taskDefMap: dict[str, lsst.pipe.base.pipeline.TaskDef], universe: DimensionUniverse) → QuantumNode¶

to_simple(accumulator: DimensionRecordsAccumulator | None = None) → SerializedQuantumNode¶