lsst.ctrl.mpexec

Changes

• Multi-Processing Executor v23.0.1 2022-02-02
• Multi-Processing Executor v23.0.0 2021-12-10
• Multi-Processing Executor v22.0 2021-04-01

Contributing

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

Command Line Scripts

• pipetask

Python API reference

lsst.ctrl.mpexec Package

Functions

graph2dot(qgraph, file)	Convert QuantumGraph into GraphViz digraph.
pipeline2dot(pipeline, file)	Convert Pipeline into GraphViz digraph.

Classes

CmdLineFwk()	PipelineTask framework which executes tasks from command line.
ExecutionGraphFixup	Interface for classes which update quantum graphs before execution.
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.
PreExecInit(butler, taskFactory[, …])	Initialization of registry for QuantumGraph execution.
QuantumExecutor	Class which abstracts execution of a single Quantum.
QuantumGraphExecutor	Class which abstracts QuantumGraph execution.
SimplePipelineExecutor(quantum_graph, butler)	A simple, high-level executor for pipelines.
SingleQuantumExecutor(taskFactory[, …])	Executor class which runs one Quantum at a time.
TaskFactory	Class instantiating PipelineTasks.