lsst.ctrl.mpexec

Changes

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.

Configuring Execution Using Pipetask

Command Line Scripts

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.

ExceptionInfo(*, className, message)

Information about exception.

ExecutionGraphFixup()

Interface for classes which update quantum graphs before execution.

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.

QuantumExecutor()

Class which abstracts execution of a single Quantum.

QuantumGraphExecutor()

Class which abstracts QuantumGraph execution.

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

Task execution report for a single Quantum.

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

Execution report for the whole job with one or few quanta.

SeparablePipelineExecutor(butler[, ...])

An executor that allows each step of pipeline execution to be run independently.

SimplePipelineExecutor(quantum_graph, butler)

A simple, high-level executor for pipelines.

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

Executor class which runs one Quantum at a time.

TaskFactory()

Class instantiating PipelineTasks.