BaseQuantumGraphReader

class lsst.pipe.base.quantum_graph.BaseQuantumGraphReader(header: HeaderModel, pipeline_graph: PipelineGraph, zf: ZipFile, decompressor: Decompressor, address_reader: AddressReader, page_size: int)

Bases: object

A helper class for reading quantum graphs.

Attributes Summary

address_reader	A helper object for reading addresses into the multi-block files.
decompressor	A decompressor for all compressed JSON blocks.
header	Header metadata for the quantum graph.
page_size	Approximate number of bytes to read at a time.
pipeline_graph	Graph of tasks and dataset type names that appear in the quantum graph.
zf	The zip archive that represents the quantum graph on disk.

Attributes Documentation

address_reader: AddressReader = <dataclasses._MISSING_TYPE object>

A helper object for reading addresses into the multi-block files.

decompressor: Decompressor = <dataclasses._MISSING_TYPE object>

A decompressor for all compressed JSON blocks.

header: HeaderModel = <dataclasses._MISSING_TYPE object>

Header metadata for the quantum graph.

page_size: int = <dataclasses._MISSING_TYPE object>

Approximate number of bytes to read at a time.

Note that this does not set a page size for all reads, but it does affect the smallest, most numerous reads.

pipeline_graph: PipelineGraph = <dataclasses._MISSING_TYPE object>

Graph of tasks and dataset type names that appear in the quantum graph.

zf: ZipFile = <dataclasses._MISSING_TYPE object>

The zip archive that represents the quantum graph on disk.