CmdLineFwk() |
PipelineTask framework which executes tasks from command line. |
ExecutionGraphFixup |
Interface for classes which update quantum graphs before execution. |
ExecutionStatus |
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. |
PreExecInit(butler, taskFactory, extendRun, mock) |
Initialization of registry for QuantumGraph execution. |
QuantumExecutor |
Class which abstracts execution of a single Quantum. |
QuantumGraphExecutor |
Class which abstracts QuantumGraph execution. |
QuantumReport(dataId, Mapping[str, Any]], …) |
Task execution report for a single Quantum. |
Report |
Execution report for the whole job with one or few quanta. |
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. |