QuantumExecutionResult

class lsst.pipe.base.quantum_graph_executor.QuantumExecutionResult(quantum: Quantum, report: QuantumReport | None, *, task_metadata: TaskMetadata | None = None, skipped_existing: bool | None = None, adjusted_no_work: bool | None = None)

Bases: tuple[Quantum, QuantumReport | None]

A result struct that captures information about a single quantum’s execution.

Parameters:

quantumlsst.daf.butler.Quantum

Quantum that was executed.

reportquantum_reports.QuantumReport

Report with basic information about the execution.

task_metadataTaskMetadata, optional

Metadata saved by the task and executor during execution.

skipped_existingbool, optional

If True, this quantum was not executed because it appeared to have already been executed successfully.

adjusted_no_workbool, optional

If True, this quantum was not executed because the PipelineTaskConnections.adjustQuanta hook raised NoWorkFound.

Notes

For backwards compatibility, this class is a two-element tuple that allows the quantum and report attributes to be unpacked. Additional regular attributes may be added by executors (but the tuple must remain only two elements to enable the current unpacking interface).

Attributes Summary

adjusted_no_work	If True, this quantum was not executed because the PipelineTaskConnections.adjustQuanta hook raised NoWorkFound.
quantum	The quantum actually executed.
report	Structure describing the status of the execution of a quantum.
skipped_existing	If True, this quantum was not executed because it appeared to have already been executed successfully.
task_metadata	Metadata saved by the task and executor during execution.

Methods Summary

count(value, /)	Return number of occurrences of value.
index(value[, start, stop])	Return first index of value.

Attributes Documentation

adjusted_no_work

If True, this quantum was not executed because the PipelineTaskConnections.adjustQuanta hook raised NoWorkFound.

quantum

The quantum actually executed.

report

Structure describing the status of the execution of a quantum.

This is None if the implementation does not support this feature.

skipped_existing

If True, this quantum was not executed because it appeared to have already been executed successfully.

task_metadata

Metadata saved by the task and executor during execution.

Methods Documentation

count(value, /)

Return number of occurrences of value.

index(value, start=0, stop=sys.maxsize, /)

Return first index of value.

Raises ValueError if the value is not present.