PredictedQuantumDatasetsModel

class lsst.pipe.base.quantum_graph.PredictedQuantumDatasetsModel(*, quantum_id: ~uuid.UUID, task_label: str, data_coordinate: list[int | str] = <factory>, inputs: dict[str, list[~lsst.pipe.base.quantum_graph._predicted.PredictedDatasetModel]] = <factory>, outputs: dict[str, list[~lsst.pipe.base.quantum_graph._predicted.PredictedDatasetModel]] = <factory>, datastore_records: dict[str, ~lsst.daf.butler.datastore.record_data.SerializedDatastoreRecordData] = <factory>)

Bases: BaseModel

Data model for a description of a single predicted quantum that includes its inputs and outputs.

Attributes Summary

model_config

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

Methods Summary

copy(*args, **kwargs)	See pydantic.BaseModel.copy.
deserialize_datastore_records()	Deserialize the mapping of datastore records.
from_execution_quantum(task_node, quantum, ...)	Construct from an lsst.daf.butler.Quantum instance.
from_old_quantum_graph_init(task_init_node, ...)	Construct from the init-input and init-output dataset types of a task in an old QuantumGraph instance.
iter_dataset_ids()	Return an iterator over the UUIDs of all datasets referenced by this quantum.
iter_input_dataset_ids()	Return an iterator over the UUIDs of all datasets consumed by this quantum.
iter_output_dataset_ids()	Return an iterator over the UUIDs of all datasets produced by this quantum.
model_construct(*args, **kwargs)	See pydantic.BaseModel.model_construct.
model_copy(*args, **kwargs)	See pydantic.BaseModel.model_copy.
model_dump(*args, **kwargs)	See pydantic.BaseModel.model_dump.
model_dump_json(*args, **kwargs)	See pydantic.BaseModel.model_dump_json.
model_json_schema(*args, **kwargs)	See pydantic.BaseModel.model_json_schema.
model_validate(*args, **kwargs)	See pydantic.BaseModel.model_validate.
model_validate_json(*args, **kwargs)	See pydantic.BaseModel.model_validate_json.
model_validate_strings(*args, **kwargs)	See pydantic.BaseModel.model_validate_strings.

Attributes Documentation

model_config: ClassVar[ConfigDict] = {}

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

Methods Documentation

copy(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.copy.

deserialize_datastore_records() → dict[str, DatastoreRecordData]

Deserialize the mapping of datastore records.

classmethod from_execution_quantum(task_node: TaskNode, quantum: Quantum, quantum_id: UUID) → PredictedQuantumDatasetsModel

Construct from an lsst.daf.butler.Quantum instance.

Parameters

task_nodepipeline_graph.TaskNode

Task node from the pipeline graph.

quantumlsst.daf.butler.quantum

Quantum object.

quantum_iduuid.UUID

ID for this quantum.

Returns

modelPredictedFullQuantumModel

Model for this quantum.

classmethod from_old_quantum_graph_init(task_init_node: TaskInitNode, old_quantum_graph: QuantumGraph) → PredictedQuantumDatasetsModel

Construct from the init-input and init-output dataset types of a task in an old QuantumGraph instance.

Parameters

task_init_nodepipeline_graph.TaskNode

Task init node from the pipeline graph.

old_quantum_graphQuantumGraph

Quantum graph.

Returns

modelPredictedFullQuantumModel

Model for this “init” quantum.

iter_dataset_ids() → Iterator[UUID]

Return an iterator over the UUIDs of all datasets referenced by this quantum.

Returns

iterIterator [ uuid.UUID ]

Iterator over dataset IDs.

iter_input_dataset_ids() → Iterator[UUID]

Return an iterator over the UUIDs of all datasets consumed by this quantum.

Returns

iterIterator [ uuid.UUID ]

Iterator over dataset IDs.

iter_output_dataset_ids() → Iterator[UUID]

Return an iterator over the UUIDs of all datasets produced by this quantum.

Returns

iterIterator [ uuid.UUID ]

Iterator over dataset IDs.

classmethod model_construct(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_construct.

model_copy(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_copy.

model_dump(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_dump.

model_dump_json(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_dump_json.

classmethod model_json_schema(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_json_schema.

classmethod model_validate(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_validate.

classmethod model_validate_json(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_validate_json.

classmethod model_validate_strings(*args: Any, **kwargs: Any) → Any

See pydantic.BaseModel.model_validate_strings.