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

numProcint

Number of processes to use for executing tasks.

timeoutfloat

Time in seconds to wait for tasks to finish.

quantumExecutorlsst.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.

startMethodstr, optional

Start method from multiprocessing module, None selects the best one for current platform.

failFastbool, optional

If set to True then stop processing on first error from any task.

pdbstr, optional

Debugger to import and use (via the post_mortem function) in the event of an exception.

executionGraphFixuplsst.pipe.base.execution_graph_fixup.ExecutionGraphFixup, optional

Instance used for modification of execution graph.

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

Attributes Summary

executionGraphFixup
failFast
numProc
pdb
quantumExecutor
report
startMethod
timeout

Attributes Documentation

executionGraphFixup

failFast

numProc

pdb

quantumExecutor

report

startMethod

timeout