QuantumNode#

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

Bases: object

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, TaskDef], universe: DimensionUniverse) → QuantumNode#

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