PrerequisiteBounds

class lsst.pipe.base.prerequisite_helpers.PrerequisiteBounds(task_node: ~lsst.pipe.base.pipeline_graph._tasks.TaskNode, all_dataset_skypix: dict[str, ~lsst.daf.butler.dimensions._skypix.SkyPixDimension] = <factory>, any_dataset_has_timespan: bool = False)

Bases: object

A QuantumGraph-generation helper class that manages the spatial and temporal bounds of a tasks’ quanta, for the purpose of finding prerequisite inputs.

Attributes Summary

all_dataset_skypix	The union of all PrerequisiteFinder.dataset_skypix attributes for all (remaining) prerequisite finders for this task.
any_dataset_has_timespan	Whether any PrerequisiteFinder.dataset_has_timespan attribute is true for any (remaining) prerequisite finder for this task.
spatial_connections	Regular input or output connections whose (assumed spatial) data IDs should be used to define the spatial bounds of this task's quanta.
task_node	The PipelineGraph node that represents the task.
temporal_connections	Regular input or output connections whose (assumed temporal) data IDs should be used to define the temporal bounds of this task's quanta.

Methods Summary

make_skypix_bounds_builder(quantum_data_id)	Return an object that accumulates the appropriate spatial bounds for a quantum.
make_timespan_builder(quantum_data_id)	Return an object that accumulates the appropriate timespan for a quantum.

Attributes Documentation

all_dataset_skypix: dict[str, SkyPixDimension] = <dataclasses._MISSING_TYPE object>

The union of all PrerequisiteFinder.dataset_skypix attributes for all (remaining) prerequisite finders for this task.

any_dataset_has_timespan: bool = False

Whether any PrerequisiteFinder.dataset_has_timespan attribute is true for any (remaining) prerequisite finder for this task.

spatial_connections: frozenset[str] = <dataclasses._MISSING_TYPE object>

Regular input or output connections whose (assumed spatial) data IDs should be used to define the spatial bounds of this task’s quanta.

See Also

PipelineTaskConnections.getSpatialBoundsConnections

task_node: TaskNode = <dataclasses._MISSING_TYPE object>

The PipelineGraph node that represents the task.

temporal_connections: frozenset[str] = <dataclasses._MISSING_TYPE object>

Regular input or output connections whose (assumed temporal) data IDs should be used to define the temporal bounds of this task’s quanta.

See Also

PipelineTaskConnections.getTemporalBoundsConnections

Methods Documentation

make_skypix_bounds_builder(quantum_data_id: DataCoordinate) → SkyPixBoundsBuilder

Return an object that accumulates the appropriate spatial bounds for a quantum.

Parameters

quantum_data_idlsst.daf.butler.DataCoordinate

Data ID for this quantum.

Returns

builderSkyPixBoundsBuilder

Object that accumulates the appropriate spatial bounds for a quantum. If the spatial bounds are not needed, this object will do nothing.

make_timespan_builder(quantum_data_id: DataCoordinate) → TimespanBuilder

Return an object that accumulates the appropriate timespan for a quantum.

Parameters

quantum_data_idlsst.daf.butler.DataCoordinate

Data ID for this quantum.

Returns

builderTimespanBuilder

Object that accumulates the appropriate timespan bounds for a quantum. If a timespan is not needed, this object will do nothing.