WriteEdge

class lsst.pipe.base.pipeline_graph.WriteEdge(*, task_key: NodeKey, dataset_type_key: NodeKey, storage_class_name: str, connection_name: str, is_calibration: bool, raw_dimensions: frozenset[str])

Bases: Edge

Representation of an output connection (including init-outputs) in a pipeline graph.

Notes

When included in an exported networkx graph (e.g. PipelineGraph.make_xgraph), write edges set the following edge attributes:

• parent_dataset_type_name

• storage_class_name

• is_init

As with WRiteEdge instance attributes, these descriptions of dataset types are those specific to a task, and may differ from the graph’s resolved dataset type or (if PipelineGraph.resolve has not been called) there may not even be a consistent definition of the dataset type.

Attributes Summary

nodes

The directed pair of NodeKey instances this edge connects.

Methods Summary

adapt_dataset_ref(ref)	Transform the graph's definition of a dataset reference (parent dataset type, with the registry or producer's storage class) to the one seen by this task.
adapt_dataset_type(dataset_type)	Transform the graph's definition of a dataset type (parent, with the registry or producer's storage class) to the one seen by this task.

Attributes Documentation

nodes

Methods Documentation

adapt_dataset_ref(ref: DatasetRef) → DatasetRef

Transform the graph’s definition of a dataset reference (parent dataset type, with the registry or producer’s storage class) to the one seen by this task.

Parameters

refDatasetRef

Graph’s definition of the dataset reference.

Returns

out_dataset_refDatasetRef

Dataset reference seen by this task.

adapt_dataset_type(dataset_type: DatasetType) → DatasetType

Transform the graph’s definition of a dataset type (parent, with the registry or producer’s storage class) to the one seen by this task.

Parameters

dataset_typeDatasetType

Graph’s definition of dataset type.

Returns

out_dataset_typeDatasetType

Dataset type seen by this task.