lsst.ctrl.mpexec#

Changes#

Contributing#

lsst.ctrl.mpexec is developed at lsst/ctrl_mpexec. You can find Jira issues for this module under the ctrl_mpexec component.

Configuring Execution Using Pipetask#

Command Line Scripts#

Python API reference#

lsst.ctrl.mpexec Package#

Classes#

ExceptionInfo(*, className, message)

ExecutionGraphFixup()

ExecutionStatus(value[, names, module, ...])

Possible values for job execution status.

MPGraphExecutor(numProc, timeout, ...[, ...])

Implementation of QuantumGraphExecutor using same-host multiprocess execution of Quanta.

MPGraphExecutorError

Exception class for errors raised by MPGraphExecutor.

MPTimeoutError

Exception raised when task execution times out.

PipelineGraphFactory([pipeline, butler, ...])

A factory for building and caching a PipelineGraph.

PreExecInit(butler, taskFactory[, extendRun])

Initialization of registry for QuantumGraph execution.

PreExecInitBase(butler, taskFactory, extendRun)

Common part of the implementation of PreExecInit classes that does not depend on Butler type.

QuantumExecutor()

QuantumGraphExecutor()

QuantumReport(dataId, taskLabel[, status, ...])

Report(*, qgraphSummary[, status, cmdLine, ...])

SeparablePipelineExecutor(butler[, ...])

SimplePipelineExecutor(quantum_graph, butler)

SingleQuantumExecutor(butler, taskFactory[, ...])

Executor class which runs one Quantum at a time.

TaskFactory()