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:
- graph
QuantumGraph
Quantum Graph that will be executed by the executor.
- graph
- Returns:
- graph
QuantumGraph
Modified graph.
- 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:
- xgraph
networkx.DiGraph
A directed acyclic graph of quanta to modify in place. Node keys are quantum UUIDs, and attributes include
task_label
(str
) anddata_id
(a fulllsst.daf.butler.DataCoordinate
, without dimension records attached). Edges may be added, but not removed. Nodes may not be modified.- quanta_by_task
Mapping
[str
,Mapping
[lsst.daf.butler.DataCoordinate
,uuid.UUID
] ] All quanta in the graph, grouped first by task label and then by data ID.
- xgraph