lsst.pipe.base.graphBuilder._TaskScaffolding Class Reference

Public Member Functions
def	__init__ (self, TaskDef taskDef, _PipelineScaffolding parent, TaskDatasetTypes datasetTypes)
def	__repr__ (self)
Set[Quantum]	makeQuantumSet (self)

Public Attributes
	taskDef
	dimensions
	initInputs
	initOutputs
	inputs
	outputs
	prerequisites
	dataIds
	quanta

Detailed Description

Helper class aggregating information about a `PipelineTask`, used when
constructing a `QuantumGraph`.

See `_PipelineScaffolding` for a top-down description of the full
scaffolding data structure.

Parameters
----------
taskDef : `TaskDef`
    Data structure that identifies the task class and its config.
parent : `_PipelineScaffolding`
    The parent data structure that will hold the instance being
    constructed.
datasetTypes : `TaskDatasetTypes`
    Data structure that categorizes the dataset types used by this task.

Definition at line 266 of file graphBuilder.py.

Constructor & Destructor Documentation

__init__()

def lsst.pipe.base.graphBuilder._TaskScaffolding.__init__	(		self,
		TaskDef	taskDef,
		_PipelineScaffolding	parent,
		TaskDatasetTypes	datasetTypes
	)

Definition at line 283 of file graphBuilder.py.

    def __init__(self, taskDef: TaskDef, parent: _PipelineScaffolding, datasetTypes: TaskDatasetTypes):
        universe = parent.dimensions.universe
        self.taskDef = taskDef
        self.dimensions = DimensionGraph(universe, names=taskDef.connections.dimensions)
        assert self.dimensions.issubset(parent.dimensions)
        # Initialize _DatasetDicts as subsets of the one or two
        # corresponding dicts in the parent _PipelineScaffolding.
        self.initInputs = _DatasetDict.fromSubset(datasetTypes.initInputs, parent.initInputs,
                                                  parent.initIntermediates)
        self.initOutputs = _DatasetDict.fromSubset(datasetTypes.initOutputs, parent.initIntermediates,
                                                   parent.initOutputs)
        self.inputs = _DatasetDict.fromSubset(datasetTypes.inputs, parent.inputs, parent.intermediates)
        self.outputs = _DatasetDict.fromSubset(datasetTypes.outputs, parent.intermediates, parent.outputs)
        self.prerequisites = _DatasetDict.fromSubset(datasetTypes.prerequisites, parent.prerequisites)
        self.dataIds = set()
        self.quanta = {}
 

Member Function Documentation

__repr__()

def lsst.pipe.base.graphBuilder._TaskScaffolding.__repr__

(

self

)

Definition at line 300 of file graphBuilder.py.

    def __repr__(self):
        # Default dataclass-injected __repr__ gets caught in an infinite loop
        # because of back-references.
        return f"_TaskScaffolding(taskDef={self.taskDef}, ...)"
 

makeQuantumSet()

Set[Quantum] lsst.pipe.base.graphBuilder._TaskScaffolding.makeQuantumSet

(

self

)

Create a `set` of `Quantum` from the information in ``self``.

Returns
-------
nodes : `set` of `Quantum
    The `Quantum` elements corresponding to this task.

Definition at line 345 of file graphBuilder.py.

    def makeQuantumSet(self) -> Set[Quantum]:
        """Create a `set` of `Quantum` from the information in ``self``.
 
        Returns
        -------
        nodes : `set` of `Quantum
            The `Quantum` elements corresponding to this task.
        """
        return set(q.makeQuantum() for q in self.quanta.values())
 
 
@dataclass

Member Data Documentation

dataIds

lsst.pipe.base.graphBuilder._TaskScaffolding.dataIds

Definition at line 297 of file graphBuilder.py.

dimensions

lsst.pipe.base.graphBuilder._TaskScaffolding.dimensions

Definition at line 286 of file graphBuilder.py.

initInputs

lsst.pipe.base.graphBuilder._TaskScaffolding.initInputs

Definition at line 290 of file graphBuilder.py.

initOutputs

lsst.pipe.base.graphBuilder._TaskScaffolding.initOutputs

Definition at line 292 of file graphBuilder.py.

inputs

lsst.pipe.base.graphBuilder._TaskScaffolding.inputs

Definition at line 294 of file graphBuilder.py.

outputs

lsst.pipe.base.graphBuilder._TaskScaffolding.outputs

Definition at line 295 of file graphBuilder.py.

prerequisites

lsst.pipe.base.graphBuilder._TaskScaffolding.prerequisites

Definition at line 296 of file graphBuilder.py.

quanta

lsst.pipe.base.graphBuilder._TaskScaffolding.quanta

Definition at line 298 of file graphBuilder.py.

taskDef

lsst.pipe.base.graphBuilder._TaskScaffolding.taskDef

Definition at line 285 of file graphBuilder.py.

---

The documentation for this class was generated from the following file:

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.4.3/Linux64/pipe_base/22.0.1+94e66cc9ed/python/lsst/pipe/base/graphBuilder.py