CmdLineFwk

class lsst.ctrl.mpexec.CmdLineFwk

Bases: object

PipelineTask framework which executes tasks from command line.

In addition to executing tasks this activator provides additional methods for task management like dumping configuration or execution chain.

Attributes Summary

MP_TIMEOUT

Methods Summary

makeGraph(pipeline_graph_factory, args)	Build a graph from command line arguments.
makePipeline(args)	Build a pipeline from command line arguments.
preExecInitQBB(task_factory, args)
runGraphQBB(task_factory, args)
runPipeline(graph, taskFactory, args[, butler])	Execute complete QuantumGraph.

Attributes Documentation

MP_TIMEOUT = 2592000

Methods Documentation

makeGraph(pipeline_graph_factory: PipelineGraphFactory | None, args: SimpleNamespace) → QuantumGraph | None

Build a graph from command line arguments.

Parameters:

pipeline_graph_factoryPipelineGraphFactory

Factory that holds a pipeline and can produce a pipeline graph. Must be None if and only if graph is read from a file.

argstypes.SimpleNamespace

Parsed command line.

Returns:

graphQuantumGraph or None

If resulting graph is empty then None is returned.

makePipeline(args: SimpleNamespace) → Pipeline

Build a pipeline from command line arguments.

Parameters:

argstypes.SimpleNamespace

Parsed command line.

Returns:

pipelinePipeline

Newly-constructed pipeline.

preExecInitQBB(task_factory: TaskFactory, args: SimpleNamespace) → None

runGraphQBB(task_factory: TaskFactory, args: SimpleNamespace) → None

runPipeline(graph: QuantumGraph, taskFactory: TaskFactory, args: SimpleNamespace, butler: Butler | None = None) → None

Execute complete QuantumGraph.

Parameters:

graphQuantumGraph

Execution graph.

taskFactoryTaskFactory

Task factory.

argstypes.SimpleNamespace

Parsed command line.

butlerButler, optional

Data Butler instance, if not defined then new instance is made using command line options.