lsst.pipe.drivers.utils.TractDataIdContainer Class Reference

Inheritance diagram for lsst.pipe.drivers.utils.TractDataIdContainer:

Public Member Functions
def	makeDataRefList (self, namespace)

Public Attributes
	refList

Detailed Description

Definition at line 38 of file utils.py.

Member Function Documentation

makeDataRefList()

def lsst.pipe.drivers.utils.TractDataIdContainer.makeDataRefList	(		self,
			namespace
	)

Make self.refList from self.idList

It's difficult to make a data reference that merely points to an entire
tract: there is no data product solely at the tract level.  Instead, we
generate a list of data references for patches within the tract.

Definition at line 40 of file utils.py.

    def makeDataRefList(self, namespace):
        """Make self.refList from self.idList
 
        It's difficult to make a data reference that merely points to an entire
        tract: there is no data product solely at the tract level.  Instead, we
        generate a list of data references for patches within the tract.
        """
        datasetType = namespace.config.coaddName + "Coadd_calexp"
        validKeys = set(["tract", "filter", "patch"])
 
        def getPatchRefList(tract):
            return [namespace.butler.dataRef(datasetType=datasetType,
                                             tract=tract.getId(),
                                             filter=dataId["filter"],
                                             patch="%d,%d" % patch.getIndex())
                    for patch in tract]
 
        tractRefs = {}  # Data references for each tract
        for dataId in self.idList:
            for key in validKeys:
                if key in ("tract", "patch",):
                    # Will deal with these explicitly
                    continue
                if key not in dataId:
                    raise argparse.ArgumentError(
                        None, "--id must include " + key)
 
            skymap = self.getSkymap(namespace)
 
            if "tract" in dataId:
                tractId = dataId["tract"]
                if tractId not in tractRefs:
                    tractRefs[tractId] = []
                if "patch" in dataId:
                    tractRefs[tractId].append(namespace.butler.dataRef(datasetType=datasetType, tract=tractId,
                                                                       filter=dataId[
                                                                           'filter'],
                                                                       patch=dataId['patch']))
                else:
                    tractRefs[tractId] += getPatchRefList(skymap[tractId])
            else:
                tractRefs = dict((tract.getId(), tractRefs.get(tract.getId(), []) +
                                  getPatchRefList(tract)) for tract in skymap)
 
        self.refList = list(tractRefs.values())

Member Data Documentation

refList

lsst.pipe.drivers.utils.TractDataIdContainer.refList

Definition at line 84 of file utils.py.

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/pipe_drivers/22.0.0+a28f4c53b1/python/lsst/pipe/drivers/utils.py