QuantumGraphExecutor

class lsst.pipe.base.quantum_graph_executor.QuantumGraphExecutor

Bases: ABC

Class which abstracts QuantumGraph execution.

Any specific execution model is implemented in sub-class by overriding the execute method.

Methods Summary

execute(graph, *[, provenance_graph_file])	Execute whole graph.
getReport()	Return execution report from last call to execute.

Methods Documentation

abstract execute(graph: QuantumGraph | PredictedQuantumGraph, *, provenance_graph_file: str | None = None) → None

Execute whole graph.

Implementation of this method depends on particular execution model and it has to be provided by a subclass. Execution model determines what happens here; it can be either actual running of the task or, for example, generation of the scripts for delayed batch execution.

Parameters:

graphQuantumGraph or quantum_graph.PredictedQuantumGraph

Execution graph.

provenance_graph_filestr, optional

A filename to write provenance to.

getReport() → Report | None

Return execution report from last call to execute.

Returns:

reportReport, optional

Structure describing the status of the execution of a quantum graph. None is returned if implementation does not support this feature.

Raises:

RuntimeError

Raised if this method is called before execute.