QuantaCluster

class lsst.ctrl.bps.QuantaCluster(name, label, tags=None)

Bases: object

Information about the cluster and Quanta belonging to it.

Parameters:

namestr

Lookup key (logical file name) of file/directory. Must be unique within ClusteredQuantumGraph.

labelstr

Value used to group clusters.

tagsdict [str, Any], optional

Arbitrary key/value pairs for the cluster.

Raises:

ValueError

Raised if invalid name (e.g., name contains /).

Attributes Summary

qgraph_node_ids	Quantum graph NodeIds corresponding to this cluster.
quanta_counts	Counts of Quanta per taskDef.label in this cluster.

Methods Summary

add_quantum(node_id, task_label)	Add a quantumNode to this cluster.
add_quantum_node(quantum_node)	Add a quantumNode to this cluster.
from_quantum_node(quantum_node, template)	Create single quantum cluster from given quantum node.

Attributes Documentation

qgraph_node_ids

Quantum graph NodeIds corresponding to this cluster.

quanta_counts

Counts of Quanta per taskDef.label in this cluster.

Methods Documentation

add_quantum(node_id, task_label)

Add a quantumNode to this cluster.

Parameters:

node_idlsst.pipe.base.NodeId

ID for quantumNode to be added to cluster.

task_labelstr

Task label for quantumNode to be added to cluster.

add_quantum_node(quantum_node)

Add a quantumNode to this cluster.

Parameters:

quantum_nodelsst.pipe.base.QuantumNode

Quantum node to add.

classmethod from_quantum_node(quantum_node, template)

Create single quantum cluster from given quantum node.

Parameters:

quantum_nodelsst.pipe.base.QuantumNode

QuantumNode for which to make into a single quantum cluster.

templatestr

Template for creating cluster name.

Returns:

clusterQuantaCluster

Newly created cluster containing the given quantum.