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, lsst.pipe.base.pipeline.TaskDef], universe: DimensionUniverse) QuantumNode
to_simple(accumulator: DimensionRecordsAccumulator | None = None) SerializedQuantumNode