lsst.pipe.tasks.postprocess.TractObjectDataIdContainer Class Reference

Inheritance diagram for lsst.pipe.tasks.postprocess.TractObjectDataIdContainer:

Public Member Functions
def	makeDataRefList (self, namespace)
def	getSkymap (self, namespace)

Public Attributes
	refList

Detailed Description

Definition at line 756 of file postprocess.py.

Member Function Documentation

getSkymap()

def lsst.coadd.utils.coaddDataIdContainer.CoaddDataIdContainer.getSkymap (   self,   namespace  )

inherited

Only retrieve skymap if required

Definition at line 37 of file coaddDataIdContainer.py.

    def getSkymap(self, namespace):
        """Only retrieve skymap if required"""
        if not hasattr(self, "_skymap"):
            self._skymap = namespace.butler.get(namespace.config.coaddName + "Coadd_skyMap")
        return self._skymap
 

makeDataRefList()

def lsst.pipe.tasks.postprocess.TractObjectDataIdContainer.makeDataRefList	(		self,
			namespace
	)

Make self.refList from self.idList

Generate a list of data references given tract and/or patch.
This was adapted from `TractQADataIdContainer`, which was
`TractDataIdContainer` modifie to not require "filter".
Only existing dataRefs are returned.

Reimplemented from lsst.coadd.utils.coaddDataIdContainer.CoaddDataIdContainer.

Definition at line 758 of file postprocess.py.

    def makeDataRefList(self, namespace):
        """Make self.refList from self.idList
 
        Generate a list of data references given tract and/or patch.
        This was adapted from `TractQADataIdContainer`, which was
        `TractDataIdContainer` modifie to not require "filter".
        Only existing dataRefs are returned.
        """
        def getPatchRefList(tract):
            return [namespace.butler.dataRef(datasetType=self.datasetType,
                                             tract=tract.getId(),
                                             patch="%d,%d" % patch.getIndex()) for patch in tract]
 
        tractRefs = defaultdict(list)  # Data references for each tract
        for dataId in self.idList:
            skymap = self.getSkymap(namespace)
 
            if "tract" in dataId:
                tractId = dataId["tract"]
                if "patch" in dataId:
                    tractRefs[tractId].append(namespace.butler.dataRef(datasetType=self.datasetType,
                                                                       tract=tractId,
                                                                       patch=dataId['patch']))
                else:
                    tractRefs[tractId] += getPatchRefList(skymap[tractId])
            else:
                tractRefs = dict((tract.getId(), tractRefs.get(tract.getId(), []) + getPatchRefList(tract))
                                 for tract in skymap)
        outputRefList = []
        for tractRefList in tractRefs.values():
            existingRefs = [ref for ref in tractRefList if ref.datasetExists()]
            outputRefList.append(existingRefs)
 
        self.refList = outputRefList
 
 

Member Data Documentation

refList

lsst.pipe.tasks.postprocess.TractObjectDataIdContainer.refList

Definition at line 791 of file postprocess.py.

---

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

• /j/snowflake/release/lsstsw/stack/0.4.3/Linux64/pipe_tasks/21.0.0-61-ge77b8116+a869d0a5a5/python/lsst/pipe/tasks/postprocess.py