MPGraphExecutor¶
- class lsst.ctrl.mpexec.MPGraphExecutor(*args, **kwargs)¶
Bases:
MPGraphExecutor
Implementation of QuantumGraphExecutor using same-host multiprocess execution of Quanta.
This is a deprecated backwards-compatibility shim for
lsst.pipe.base.mp_graph_executor.MPGraphExecutor
, which has the same functionality with very minor interface changes.- Parameters:
- numProc
int
Number of processes to use for executing tasks.
- timeout
float
Time in seconds to wait for tasks to finish.
- quantumExecutor
lsst.pipe.base.quantum_graph_executor.QuantumExecutor
Executor for single quantum. For multiprocess-style execution when
num_proc
is greater than one this instance must support pickle.- startMethod
str
, optional Start method from
multiprocessing
module,None
selects the best one for current platform.- failFast
bool
, optional If set to
True
then stop processing on first error from any task.- pdb
str
, optional Debugger to import and use (via the
post_mortem
function) in the event of an exception.- executionGraphFixup
lsst.pipe.base.execution_graph_fixup.ExecutionGraphFixup
, optional Instance used for modification of execution graph.
- .. deprecated:: v30
The MPGraphExecutor class has moved to lsst.pipe.base.mp_graph_executor. This forwarding shim will be removed after v30.
- numProc
Attributes Summary
Methods Summary
execute
(graph)Execute whole graph.
Return execution report from last call to
execute
.Attributes Documentation
- executionGraphFixup¶
- failFast¶
- numProc¶
- pdb¶
- quantumExecutor¶
- report¶
- startMethod¶
- timeout¶
Methods Documentation
- execute(graph: QuantumGraph) None ¶
Execute whole graph.
Implementation of this method depends on particular execution model and it has to be provided by a subclass. Execution model determines what happens here; it can be either actual running of the task or, for example, generation of the scripts for delayed batch execution.
- Parameters:
- graph
QuantumGraph
Execution graph.
- graph