ProvenanceQuantumScanData

class lsst.pipe.base.quantum_graph.ProvenanceQuantumScanData(quantum_id: ~uuid.UUID, status: ~lsst.pipe.base.quantum_graph._provenance.ProvenanceQuantumScanStatus, existing_outputs: set[~uuid.UUID] = <factory>, quantum: bytes = b'', metadata: bytes = b'', logs: bytes = b'', is_compressed: bool = False)

Bases: object

A struct that represents ready-for-serialization provenance information for a single quantum.

Attributes Summary

existing_outputs	Unique IDs of the output datasets that were actually written.
is_compressed	Whether the quantum, metadata, and log attributes are compressed.
logs	Serialized logs.
metadata	Serialized task metadata.
quantum	Serialized quantum provenance model.
quantum_id	Unique ID for the quantum.
status	Combined status for the scan and the execution of the quantum.

Methods Summary

compress(compressor)

Compress the data in this struct if it has not been compressed already.

Attributes Documentation

existing_outputs: set[UUID] = <dataclasses._MISSING_TYPE object>

Unique IDs of the output datasets that were actually written.

is_compressed: bool = False

Whether the quantum, metadata, and log attributes are compressed.

logs: bytes = b''

Serialized logs.

metadata: bytes = b''

Serialized task metadata.

quantum: bytes = b''

Serialized quantum provenance model.

This may be empty for quanta that had no attempts.

quantum_id: UUID = <dataclasses._MISSING_TYPE object>

Unique ID for the quantum.

status: ProvenanceQuantumScanStatus = <dataclasses._MISSING_TYPE object>

Combined status for the scan and the execution of the quantum.

Methods Documentation

compress(compressor: Compressor) → None

Compress the data in this struct if it has not been compressed already.

Parameters

compressorCompressor

Object with a compress method that takes and returns bytes.