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. 
 
- graph
- Returns:
- graphQuantumGraph
- 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:
- 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. 
 
- xgraph