ExecutionGraphFixup

class lsst.ctrl.mpexec.ExecutionGraphFixup(*args, **kwargs)

Bases: ExecutionGraphFixup

Deprecated since version v30: The ExecutionGraphFixup class has moved to lsst.pipe.base.execution_graph_fixup. This forwarding shim will be removed after v30.

Methods Summary

fixupQuanta(graph)	Update quanta in a graph.
fixup_graph(xgraph, quanta_by_task)	Update a networkx graph of quanta in place by adding edges to further constrain the ordering.

Methods Documentation

fixupQuanta(graph: QuantumGraph) → QuantumGraph

Update quanta in a graph.

Parameters:

graphQuantumGraph

Quantum Graph that will be executed by the executor.

Returns:

graphQuantumGraph

Modified graph.

Notes

This hook is provided for backwards compatibility only.

fixup_graph(xgraph: DiGraph, quanta_by_task: Mapping[str, Mapping[DataCoordinate, UUID]]) → None

Update a networkx graph of quanta in place by adding edges to further constrain the ordering.

Parameters:

xgraphnetworkx.DiGraph

A directed acyclic graph of quanta to modify in place. Node keys are quantum UUIDs, and attributes include task_label (str) and data_id (a full lsst.daf.butler.DataCoordinate, without dimension records attached). Edges may be added, but not removed. Nodes may not be modified.

quanta_by_taskMapping [ str, Mapping [ lsst.daf.butler.DataCoordinate, uuid.UUID ] ]

All quanta in the graph, grouped first by task label and then by data ID.