PipelineDatasetTypes

class lsst.pipe.base.PipelineDatasetTypes(initInputs: FrozenSet[DatasetType], initOutputs: FrozenSet[DatasetType], initIntermediates: FrozenSet[DatasetType], inputs: FrozenSet[DatasetType], prerequisites: FrozenSet[DatasetType], intermediates: FrozenSet[DatasetType], outputs: FrozenSet[DatasetType], byTask: Mapping[str, TaskDatasetTypes])

Bases: object

An immutable struct that classifies the dataset types used in a Pipeline.

Methods Summary

fromPipeline(pipeline, *, universe)

Extract and classify the dataset types from all tasks in a Pipeline.

Methods Documentation

classmethod fromPipeline(pipeline: lsst.pipe.base.pipeline.Pipeline, *, universe: lsst.daf.butler.core.dimensions.graph.DimensionUniverse) → lsst.pipe.base.pipeline.PipelineDatasetTypes

Extract and classify the dataset types from all tasks in a Pipeline.

Parameters:

pipeline: `Pipeline`

An ordered collection of tasks that can be run together.

universe: `DimensionUniverse`

Set of all known dimensions, used to construct normalized DatasetType objects.

Returns:

types: `PipelineDatasetTypes`

The dataset types used by this Pipeline.

Raises:

ValueError

Raised if Tasks are inconsistent about which datasets are marked prerequisite. This indicates that the Tasks cannot be run as part of the same Pipeline.