check_clustering_config

lsst.ctrl.bps.check_clustering_config(cluster_config: BpsConfig, task_graph: DiGraph) → tuple[list[str], dict[str, list[str]]]

Check cluster definitions in terms of pipetask lists.

Parameters:

cluster_configlsst.ctrl.bps.BpsConfig

The cluster section from the BPS configuration.

task_graphnetworkx.DiGraph

Directed graph of tasks.

Returns:

cluster_labels: list [str]

Dependency ordered list of cluster labels (includes single quantum clusters).

ordered_tasksdict [str, networkx.DiGraph]

Mapping of cluster label to task subgraph.

Raises:

RuntimeError

Raised if task label appears in more than one cluster def or if there’s a cycle in the cluster defs.