lsst.pipe.tasks.dcrMultiBand.MergeDcrSourcesRunner Class Reference

Inheritance diagram for lsst.pipe.tasks.dcrMultiBand.MergeDcrSourcesRunner:

Static Public Member Functions
def	buildRefDict (parsedCmd)
def	getTargetList (parsedCmd, **kwargs)

Detailed Description

Task runner for the MergeSourcesTask.

Required because the run method requires a list of dataRefs
rather than a single dataRef.

Definition at line 39 of file dcrMultiBand.py.

Member Function Documentation

buildRefDict()

def lsst.pipe.tasks.dcrMultiBand.MergeDcrSourcesRunner.buildRefDict (   parsedCmd )

static

Build a hierarchical dictionary of patch references

The filter references within the list will have different subfilters.

Parameters
----------
parsedCmd : `dict`
    The parsed command
**kwargs
    Key word arguments (unused)

Returns
-------
refDict: dict
    A reference dictionary of the form {patch: {tract: {filter: {subfilter: dataRef}}}}

Raises
------
RuntimeError
    Thrown when multiple references are provided for the same combination of
    tract, patch, filter, and subfilter

Definition at line 47 of file dcrMultiBand.py.

    def buildRefDict(parsedCmd):
        """Build a hierarchical dictionary of patch references
 
        The filter references within the list will have different subfilters.
 
        Parameters
        ----------
        parsedCmd : `dict`
            The parsed command
        **kwargs
            Key word arguments (unused)
 
        Returns
        -------
        refDict: dict
            A reference dictionary of the form {patch: {tract: {filter: {subfilter: dataRef}}}}
 
        Raises
        ------
        RuntimeError
            Thrown when multiple references are provided for the same combination of
            tract, patch, filter, and subfilter
        """
        refDict = {}  # Will index this as refDict[tract][patch][filter][subfilter] = ref
        for ref in parsedCmd.id.refList:
            tract = ref.dataId["tract"]
            patch = ref.dataId["patch"]
            filter = ref.dataId["filter"]
            subfilter = ref.dataId["subfilter"]
            if tract not in refDict:
                refDict[tract] = {}
            if patch not in refDict[tract]:
                refDict[tract][patch] = {}
            if filter not in refDict[tract][patch]:
                refDict[tract][patch][filter] = {}
            if subfilter in refDict[tract][patch][filter]:
                raise RuntimeError("Multiple versions of %s" % (ref.dataId,))
            refDict[tract][patch][filter][subfilter] = ref
        return refDict
 

getTargetList()

def lsst.pipe.tasks.dcrMultiBand.MergeDcrSourcesRunner.getTargetList (   parsedCmd, **  kwargs  )

static

Provide a list of patch references for each patch, tract, filter combo.

Parameters
----------
parsedCmd:
    The parsed command
kwargs:
    Keyword arguments passed to the task

Returns
-------
targetList: list
    List of tuples, where each tuple is a (dataRef, kwargs) pair.

Reimplemented in lsst.pipe.tasks.dcrMultiBand.DeblendDcrCoaddSourcesRunner.

Definition at line 88 of file dcrMultiBand.py.

    def getTargetList(parsedCmd, **kwargs):
        """Provide a list of patch references for each patch, tract, filter combo.
 
        Parameters
        ----------
        parsedCmd:
            The parsed command
        kwargs:
            Keyword arguments passed to the task
 
        Returns
        -------
        targetList: list
            List of tuples, where each tuple is a (dataRef, kwargs) pair.
        """
        refDict = MergeDcrSourcesRunner.buildRefDict(parsedCmd)
        return [(list(f.values()), kwargs)
                for t in list(refDict.values())
                for p in list(t.values())
                for f in list(p.values())]
 
 

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/pipe_tasks/21.0.0-172-gfb10e10a+18fedfabac/python/lsst/pipe/tasks/dcrMultiBand.py