ConsolidateSourceTableTask¶
ConsolidateSourceTableTask concatenates per-detector Source Tables (dataset sourceTable) into one per-visit Source Table (dataset sourceTable_visit).
It only does I/O, and therefore has no run method.
The inputs have already been transformed to the DPDD-specified columns.
This task assumes that they are sufficiently narrow to fit all tables for a given visit in memory at once.
It is the third of three postprocessing tasks to convert a src table to a
per-visit Source Table that conforms to the standard data model. The first is
WriteSourceTableTask. The second is TransformSourceTableTask.
Processing summary¶
ConsolidateSourceTableTask reads in all detector-level Source Tables (dataset sourceTable) for a given visit, concatenates them, and writes the result out as a visit-level Source Table (dataset sourceTable_visit)
Python API summary¶
from lsst.pipe.tasks.postprocess import ConsolidateSourceTableTask
-
class
(*, config: Optional[PipelineTaskConfig] = None, log: Optional[Union[logging.Logger, LsstLogAdapter]] = None, initInputs: Optional[Dict[str, Any]] = None, **kwargs)ConsolidateSourceTableTask Concatenate `sourceTable` list into a per-visit `sourceTable_visit`
...
-
attribute
config Access configuration fields and retargetable subtasks.
See also
See the ConsolidateSourceTableTask API reference for complete details.
Butler datasets¶
When run through the runQuantum method, ConsolidateSourceTableTask obtains datasets from the input Butler data repository and persists outputs to the output Butler data repository.
Note that configurations for ConsolidateSourceTableTask, and its subtasks, affect what datasets are persisted and what their content is.
Retargetable subtasks¶
No subtasks.
Configuration fields¶
connections¶
- Data type
lsst.pipe.base.config.Connections- Field type
ConfigField