LSST Applications
21.0.0-172-gfb10e10a+18fedfabac,22.0.0+297cba6710,22.0.0+80564b0ff1,22.0.0+8d77f4f51a,22.0.0+a28f4c53b1,22.0.0+dcf3732eb2,22.0.1-1-g7d6de66+2a20fdde0d,22.0.1-1-g8e32f31+297cba6710,22.0.1-1-geca5380+7fa3b7d9b6,22.0.1-12-g44dc1dc+2a20fdde0d,22.0.1-15-g6a90155+515f58c32b,22.0.1-16-g9282f48+790f5f2caa,22.0.1-2-g92698f7+dcf3732eb2,22.0.1-2-ga9b0f51+7fa3b7d9b6,22.0.1-2-gd1925c9+bf4f0e694f,22.0.1-24-g1ad7a390+a9625a72a8,22.0.1-25-g5bf6245+3ad8ecd50b,22.0.1-25-gb120d7b+8b5510f75f,22.0.1-27-g97737f7+2a20fdde0d,22.0.1-32-gf62ce7b1+aa4237961e,22.0.1-4-g0b3f228+2a20fdde0d,22.0.1-4-g243d05b+871c1b8305,22.0.1-4-g3a563be+32dcf1063f,22.0.1-4-g44f2e3d+9e4ab0f4fa,22.0.1-42-gca6935d93+ba5e5ca3eb,22.0.1-5-g15c806e+85460ae5f3,22.0.1-5-g58711c4+611d128589,22.0.1-5-g75bb458+99c117b92f,22.0.1-6-g1c63a23+7fa3b7d9b6,22.0.1-6-g50866e6+84ff5a128b,22.0.1-6-g8d3140d+720564cf76,22.0.1-6-gd805d02+cc5644f571,22.0.1-8-ge5750ce+85460ae5f3,master-g6e05de7fdc+babf819c66,master-g99da0e417a+8d77f4f51a,w.2021.48
LSST Data Management Base Package
|
Classes | |
class | AssembleCoaddConnections |
class | AssembleCoaddDataIdContainer |
class | SafeClipAssembleCoaddConfig |
class | SafeClipAssembleCoaddTask |
class | CompareWarpAssembleCoaddConnections |
class | CompareWarpAssembleCoaddConfig |
class | CompareWarpAssembleCoaddTask |
Functions | |
def | processResults (self, coaddExposure, brightObjectMasks=None, dataId=None) |
def | makeSupplementaryData (self, dataRef, selectDataList=None, warpRefList=None) |
def | makeSupplementaryDataGen3 (self, butlerQC, inputRefs, outputRefs) |
def | getTempExpRefList (self, patchRef, calExpRefList) |
def | prepareInputs (self, refList) |
def | prepareStats (self, mask=None) |
def | run (self, skyInfo, tempExpRefList, imageScalerList, weightList, altMaskList=None, mask=None, supplementaryData=None) |
def | assembleMetadata (self, coaddExposure, tempExpRefList, weightList) |
def | assembleSubregion (self, coaddExposure, bbox, tempExpRefList, imageScalerList, weightList, altMaskList, statsFlags, statsCtrl, nImage=None) |
def | assembleOnlineMeanCoadd (self, coaddExposure, tempExpRefList, imageScalerList, weightList, altMaskList, statsCtrl, nImage=None) |
def | removeMaskPlanes (self, maskedImage) |
def | applyAltMaskPlanes (self, mask, altMaskSpans) |
def | shrinkValidPolygons (self, coaddInputs) |
def | readBrightObjectMasks (self, dataRef) |
def | setBrightObjectMasks (self, exposure, brightObjectMasks, dataId=None) |
def | setInexactPsf (self, mask) |
def | filterWarps (self, inputs, goodVisits) |
def | countMaskFromFootprint (mask, footprint, bitmask, ignoreMask) |
Variables | |
log = logging.getLogger(__name__) | |
id | |
KEY | |
patch | |
tract | |
filter | |
visit | |
ccd | |
skyInfo | |
calExpRefList | |
warpRefList | |
inputData | |
supplementaryData | |
retStruct | |
brightObjects | |
coaddDatasetName | |
warpType | |
def lsst.pipe.tasks.assembleCoadd.applyAltMaskPlanes | ( | self, | |
mask, | |||
altMaskSpans | |||
) |
Apply in place alt mask formatted as SpanSets to a mask. Parameters ---------- mask : `lsst.afw.image.Mask` Original mask. altMaskSpans : `dict` SpanSet lists to apply. Each element contains the new mask plane name (e.g. "CLIPPED and/or "NO_DATA") as the key, and list of SpanSets to apply to the mask. Returns ------- mask : `lsst.afw.image.Mask` Updated mask.
Definition at line 1133 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.assembleMetadata | ( | self, | |
coaddExposure, | |||
tempExpRefList, | |||
weightList | |||
) |
Set the metadata for the coadd. This basic implementation sets the filter from the first input. Parameters ---------- coaddExposure : `lsst.afw.image.Exposure` The target exposure for the coadd. tempExpRefList : `list` List of data references to tempExp. weightList : `list` List of weights.
Definition at line 868 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.assembleOnlineMeanCoadd | ( | self, | |
coaddExposure, | |||
tempExpRefList, | |||
imageScalerList, | |||
weightList, | |||
altMaskList, | |||
statsCtrl, | |||
nImage = None |
|||
) |
Assemble the coadd using the "online" method. This method takes a running sum of images and weights to save memory. It only works for MEAN statistics. Parameters ---------- coaddExposure : `lsst.afw.image.Exposure` The target exposure for the coadd. tempExpRefList : `list` List of data reference to tempExp. imageScalerList : `list` List of image scalers. weightList : `list` List of weights. altMaskList : `list` List of alternate masks to use rather than those stored with tempExp, or None. Each element is dict with keys = mask plane name to which to add the spans. statsCtrl : `lsst.afw.math.StatisticsControl` Statistics control object for coadd nImage : `lsst.afw.image.ImageU`, optional Keeps track of exposure count for each pixel.
Definition at line 1012 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.assembleSubregion | ( | self, | |
coaddExposure, | |||
bbox, | |||
tempExpRefList, | |||
imageScalerList, | |||
weightList, | |||
altMaskList, | |||
statsFlags, | |||
statsCtrl, | |||
nImage = None |
|||
) |
Assemble the coadd for a sub-region. For each coaddTempExp, check for (and swap in) an alternative mask if one is passed. Remove mask planes listed in `config.removeMaskPlanes`. Finally, stack the actual exposures using `lsst.afw.math.statisticsStack` with the statistic specified by statsFlags. Typically, the statsFlag will be one of lsst.afw.math.MEAN for a mean-stack or `lsst.afw.math.MEANCLIP` for outlier rejection using an N-sigma clipped mean where N and iterations are specified by statsCtrl. Assign the stacked subregion back to the coadd. Parameters ---------- coaddExposure : `lsst.afw.image.Exposure` The target exposure for the coadd. bbox : `lsst.geom.Box` Sub-region to coadd. tempExpRefList : `list` List of data reference to tempExp. imageScalerList : `list` List of image scalers. weightList : `list` List of weights. altMaskList : `list` List of alternate masks to use rather than those stored with tempExp, or None. Each element is dict with keys = mask plane name to which to add the spans. statsFlags : `lsst.afw.math.Property` Property object for statistic for coadd. statsCtrl : `lsst.afw.math.StatisticsControl` Statistics control object for coadd. nImage : `lsst.afw.image.ImageU`, optional Keeps track of exposure count for each pixel.
Definition at line 931 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.countMaskFromFootprint | ( | mask, | |
footprint, | |||
bitmask, | |||
ignoreMask | |||
) |
Function to count the number of pixels with a specific mask in a footprint. Find the intersection of mask & footprint. Count all pixels in the mask that are in the intersection that have bitmask set but do not have ignoreMask set. Return the count. Parameters ---------- mask : `lsst.afw.image.Mask` Mask to define intersection region by. footprint : `lsst.afw.detection.Footprint` Footprint to define the intersection region by. bitmask Specific mask that we wish to count the number of occurances of. ignoreMask Pixels to not consider. Returns ------- result : `int` Count of number of pixels in footprint with specified mask.
Definition at line 1369 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.filterWarps | ( | self, | |
inputs, | |||
goodVisits | |||
) |
Return list of only inputRefs with visitId in goodVisits ordered by goodVisit Parameters ---------- inputs : list List of `lsst.pipe.base.connections.DeferredDatasetRef` with dataId containing visit goodVisit : `dict` Dictionary with good visitIds as the keys. Value ignored. Returns: -------- filteredInputs : `list` Filtered and sorted list of `lsst.pipe.base.connections.DeferredDatasetRef`
Definition at line 1318 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.getTempExpRefList | ( | self, | |
patchRef, | |||
calExpRefList | |||
) |
Generate list data references corresponding to warped exposures that lie within the patch to be coadded. Parameters ---------- patchRef : `dataRef` Data reference for patch. calExpRefList : `list` List of data references for input calexps. Returns ------- tempExpRefList : `list` List of Warp/CoaddTempExp data references.
Definition at line 632 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.makeSupplementaryData | ( | self, | |
dataRef, | |||
selectDataList = None , |
|||
warpRefList = None |
|||
) |
Make additional inputs to run() specific to subclasses (Gen2) Duplicates interface of `runDataRef` method Available to be implemented by subclasses only if they need the coadd dataRef for performing preliminary processing before assembling the coadd. Parameters ---------- dataRef : `lsst.daf.persistence.ButlerDataRef` Butler data reference for supplementary data. selectDataList : `list` (optional) Optional List of data references to Calexps. warpRefList : `list` (optional) Optional List of data references to Warps.
Definition at line 589 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.makeSupplementaryDataGen3 | ( | self, | |
butlerQC, | |||
inputRefs, | |||
outputRefs | |||
) |
Make additional inputs to run() specific to subclasses (Gen3) Duplicates interface of `runQuantum` method. Available to be implemented by subclasses only if they need the coadd dataRef for performing preliminary processing before assembling the coadd. Parameters ---------- butlerQC : `lsst.pipe.base.ButlerQuantumContext` Gen3 Butler object for fetching additional data products before running the Task specialized for quantum being processed inputRefs : `lsst.pipe.base.InputQuantizedConnection` Attributes are the names of the connections describing input dataset types. Values are DatasetRefs that task consumes for corresponding dataset type. DataIds are guaranteed to match data objects in ``inputData``. outputRefs : `lsst.pipe.base.OutputQuantizedConnection` Attributes are the names of the connections describing output dataset types. Values are DatasetRefs that task is to produce for corresponding dataset type.
Definition at line 608 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.prepareInputs | ( | self, | |
refList | |||
) |
Prepare the input warps for coaddition by measuring the weight for each warp and the scaling for the photometric zero point. Each Warp has its own photometric zeropoint and background variance. Before coadding these Warps together, compute a scale factor to normalize the photometric zeropoint and compute the weight for each Warp. Parameters ---------- refList : `list` List of data references to tempExp Returns ------- result : `lsst.pipe.base.Struct` Result struct with components: - ``tempExprefList``: `list` of data references to tempExp. - ``weightList``: `list` of weightings. - ``imageScalerList``: `list` of image scalers.
Definition at line 656 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.prepareStats | ( | self, | |
mask = None |
|||
) |
Prepare the statistics for coadding images. Parameters ---------- mask : `int`, optional Bit mask value to exclude from coaddition. Returns ------- stats : `lsst.pipe.base.Struct` Statistics structure with the following fields: - ``statsCtrl``: Statistics control object for coadd (`lsst.afw.math.StatisticsControl`) - ``statsFlags``: Statistic for coadd (`lsst.afw.math.Property`)
Definition at line 731 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.processResults | ( | self, | |
coaddExposure, | |||
brightObjectMasks = None , |
|||
dataId = None |
|||
) |
Interpolate over missing data and mask bright stars. Parameters ---------- coaddExposure : `lsst.afw.image.Exposure` The coadded exposure to process. dataRef : `lsst.daf.persistence.ButlerDataRef` Butler data reference for supplementary data.
Definition at line 569 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.readBrightObjectMasks | ( | self, | |
dataRef | |||
) |
Retrieve the bright object masks. Returns None on failure. Parameters ---------- dataRef : `lsst.daf.persistence.butlerSubset.ButlerDataRef` A Butler dataRef. Returns ------- result : `lsst.daf.persistence.butlerSubset.ButlerDataRef` Bright object mask from the Butler object, or None if it cannot be retrieved.
Definition at line 1187 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.removeMaskPlanes | ( | self, | |
maskedImage | |||
) |
Unset the mask of an image for mask planes specified in the config. Parameters ---------- maskedImage : `lsst.afw.image.MaskedImage` The masked image to be modified.
Definition at line 1088 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.run | ( | self, | |
skyInfo, | |||
tempExpRefList, | |||
imageScalerList, | |||
weightList, | |||
altMaskList = None , |
|||
mask = None , |
|||
supplementaryData = None |
|||
) |
Assemble a coadd from input warps Assemble the coadd using the provided list of coaddTempExps. Since the full coadd covers a patch (a large area), the assembly is performed over small areas on the image at a time in order to conserve memory usage. Iterate over subregions within the outer bbox of the patch using `assembleSubregion` to stack the corresponding subregions from the coaddTempExps with the statistic specified. Set the edge bits the coadd mask based on the weight map. Parameters ---------- skyInfo : `lsst.pipe.base.Struct` Struct with geometric information about the patch. tempExpRefList : `list` List of data references to Warps (previously called CoaddTempExps). imageScalerList : `list` List of image scalers. weightList : `list` List of weights altMaskList : `list`, optional List of alternate masks to use rather than those stored with tempExp. mask : `int`, optional Bit mask value to exclude from coaddition. supplementaryData : lsst.pipe.base.Struct, optional Struct with additional data products needed to assemble coadd. Only used by subclasses that implement `makeSupplementaryData` and override `run`. Returns ------- result : `lsst.pipe.base.Struct` Result struct with components: - ``coaddExposure``: coadded exposure (``lsst.afw.image.Exposure``). - ``nImage``: exposure count image (``lsst.afw.image.Image``), if requested. - ``inputMap``: bit-wise map of inputs, if requested. - ``warpRefList``: input list of refs to the warps ( ``lsst.daf.butler.DeferredDatasetHandle`` or ``lsst.daf.persistence.ButlerDataRef``) (unmodified) - ``imageScalerList``: input list of image scalers (unmodified) - ``weightList``: input list of weights (unmodified)
Definition at line 764 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.setBrightObjectMasks | ( | self, | |
exposure, | |||
brightObjectMasks, | |||
dataId = None |
|||
) |
Set the bright object masks. Parameters ---------- exposure : `lsst.afw.image.Exposure` Exposure under consideration. dataId : `lsst.daf.persistence.dataId` Data identifier dict for patch. brightObjectMasks : `lsst.afw.table` Table of bright objects to mask.
Definition at line 1209 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.setInexactPsf | ( | self, | |
mask | |||
) |
Set INEXACT_PSF mask plane. If any of the input images isn't represented in the coadd (due to clipped pixels or chip gaps), the `CoaddPsf` will be inexact. Flag these pixels. Parameters ---------- mask : `lsst.afw.image.Mask` Coadded exposure's mask, modified in-place.
Definition at line 1251 of file assembleCoadd.py.
def lsst.pipe.tasks.assembleCoadd.shrinkValidPolygons | ( | self, | |
coaddInputs | |||
) |
Shrink coaddInputs' ccds' ValidPolygons in place. Either modify each ccd's validPolygon in place, or if CoaddInputs does not have a validPolygon, create one from its bbox. Parameters ---------- coaddInputs : `lsst.afw.image.coaddInputs` Original mask.
Definition at line 1165 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.brightObjects |
Definition at line 554 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.calExpRefList |
Definition at line 534 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.ccd |
Definition at line 383 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.coaddDatasetName |
Definition at line 559 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.filter |
Definition at line 382 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.id |
warpType = pexConfig.Field( doc="Warp name: one of 'direct' or 'psfMatched'", dtype=str, default="direct", ) subregionSize = pexConfig.ListField( dtype=int, doc="Width, height of stack subregion size; " "make small enough that a full stack of images will fit into memory at once.", length=2, default=(2000, 2000), ) statistic = pexConfig.Field( dtype=str, doc="Main stacking statistic for aggregating over the epochs.", default="MEANCLIP", ) doOnlineForMean = pexConfig.Field( dtype=bool, doc="Perform online coaddition when statistic=\"MEAN\" to save memory?", default=False, ) doSigmaClip = pexConfig.Field( dtype=bool, doc="Perform sigma clipped outlier rejection with MEANCLIP statistic? (DEPRECATED)", default=False, ) sigmaClip = pexConfig.Field( dtype=float, doc="Sigma for outlier rejection; ignored if non-clipping statistic selected.", default=3.0, ) clipIter = pexConfig.Field( dtype=int, doc="Number of iterations of outlier rejection; ignored if non-clipping statistic selected.", default=2, ) calcErrorFromInputVariance = pexConfig.Field( dtype=bool, doc="Calculate coadd variance from input variance by stacking statistic." "Passed to StatisticsControl.setCalcErrorFromInputVariance()", default=True, ) scaleZeroPoint = pexConfig.ConfigurableField( target=ScaleZeroPointTask, doc="Task to adjust the photometric zero point of the coadd temp exposures", ) doInterp = pexConfig.Field( doc="Interpolate over NaN pixels? Also extrapolate, if necessary, but the results are ugly.", dtype=bool, default=True, ) interpImage = pexConfig.ConfigurableField( target=InterpImageTask, doc="Task to interpolate (and extrapolate) over NaN pixels", ) doWrite = pexConfig.Field( doc="Persist coadd?", dtype=bool, default=True, ) doNImage = pexConfig.Field( doc="Create image of number of contributing exposures for each pixel", dtype=bool, default=False, ) doUsePsfMatchedPolygons = pexConfig.Field( doc="Use ValidPolygons from shrunk Psf-Matched Calexps? Should be set to True by CompareWarp only.", dtype=bool, default=False, ) maskPropagationThresholds = pexConfig.DictField( keytype=str, itemtype=float, doc=("Threshold (in fractional weight) of rejection at which we propagate a mask plane to " "the coadd; that is, we set the mask bit on the coadd if the fraction the rejected frames " "would have contributed exceeds this value."), default={"SAT": 0.1}, ) removeMaskPlanes = pexConfig.ListField(dtype=str, default=["NOT_DEBLENDED"], doc="Mask planes to remove before coadding") doMaskBrightObjects = pexConfig.Field(dtype=bool, default=False, doc="Set mask and flag bits for bright objects?") brightObjectMaskName = pexConfig.Field(dtype=str, default="BRIGHT_OBJECT", doc="Name of mask bit used for bright objects") coaddPsf = pexConfig.ConfigField( doc="Configuration for CoaddPsf", dtype=measAlg.CoaddPsfConfig, ) doAttachTransmissionCurve = pexConfig.Field( dtype=bool, default=False, optional=False, doc=("Attach a piecewise TransmissionCurve for the coadd? " "(requires all input Exposures to have TransmissionCurves).") ) hasFakes = pexConfig.Field( dtype=bool, default=False, doc="Should be set to True if fake sources have been inserted into the input data." ) doSelectVisits = pexConfig.Field( doc="Coadd only visits selected by a SelectVisitsTask", dtype=bool, default=False, ) doInputMap = pexConfig.Field( doc="Create a bitwise map of coadd inputs", dtype=bool, default=False, ) inputMapper = pexConfig.ConfigurableField( doc="Input map creation subtask.", target=HealSparseInputMapTask, ) def setDefaults(self): super().setDefaults() self.badMaskPlanes = ["NO_DATA", "BAD", "SAT", "EDGE"] def validate(self): super().validate() if self.doPsfMatch: # Backwards compatibility. # Configs do not have loggers log.warning("Config doPsfMatch deprecated. Setting warpType='psfMatched'") self.warpType = 'psfMatched' if self.doSigmaClip and self.statistic != "MEANCLIP": log.warning('doSigmaClip deprecated. To replicate behavior, setting statistic to "MEANCLIP"') self.statistic = "MEANCLIP" if self.doInterp and self.statistic not in ['MEAN', 'MEDIAN', 'MEANCLIP', 'VARIANCE', 'VARIANCECLIP']: raise ValueError("Must set doInterp=False for statistic=%s, which does not " "compute and set a non-zero coadd variance estimate." % (self.statistic)) unstackableStats = ['NOTHING', 'ERROR', 'ORMASK'] if not hasattr(afwMath.Property, self.statistic) or self.statistic in unstackableStats: stackableStats = [str(k) for k in afwMath.Property.__members__.keys() if str(k) not in unstackableStats] raise ValueError("statistic %s is not allowed. Please choose one of %s." % (self.statistic, stackableStats)) class AssembleCoaddTask(CoaddBaseTask, pipeBase.PipelineTask):
Definition at line 344 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.inputData |
Definition at line 542 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.KEY |
Definition at line 344 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.log = logging.getLogger(__name__) |
Definition at line 56 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.patch |
Definition at line 382 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.retStruct |
Definition at line 551 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.skyInfo |
ConfigClass = AssembleCoaddConfig _DefaultName = "assembleCoadd" def __init__(self, *args, **kwargs): # TODO: DM-17415 better way to handle previously allowed passed args e.g.`AssembleCoaddTask(config)` if args: argNames = ["config", "name", "parentTask", "log"] kwargs.update({k: v for k, v in zip(argNames, args)}) warnings.warn("AssembleCoadd received positional args, and casting them as kwargs: %s. " "PipelineTask will not take positional args" % argNames, FutureWarning) super().__init__(**kwargs) self.makeSubtask("interpImage") self.makeSubtask("scaleZeroPoint") if self.config.doMaskBrightObjects: mask = afwImage.Mask() try: self.brightObjectBitmask = 1 << mask.addMaskPlane(self.config.brightObjectMaskName) except pexExceptions.LsstCppException: raise RuntimeError("Unable to define mask plane for bright objects; planes used are %s" % mask.getMaskPlaneDict().keys()) del mask if self.config.doInputMap: self.makeSubtask("inputMapper") self.warpType = self.config.warpType @utils.inheritDoc(pipeBase.PipelineTask) def runQuantum(self, butlerQC, inputRefs, outputRefs): # Docstring to be formatted with info from PipelineTask.runQuantum
inputData = butlerQC.get(inputRefs) # Construct skyInfo expected by run # Do not remove skyMap from inputData in case makeSupplementaryDataGen3 needs it skyMap = inputData["skyMap"] outputDataId = butlerQC.quantum.dataId inputData['skyInfo'] = makeSkyInfo(skyMap, tractId=outputDataId['tract'], patchId=outputDataId['patch']) if self.config.doSelectVisits: warpRefList = self.filterWarps(inputData['inputWarps'], inputData['selectedVisits']) else: warpRefList = inputData['inputWarps'] # Perform same middle steps as `runDataRef` does inputs = self.prepareInputs(warpRefList) self.log.info("Found %d %s", len(inputs.tempExpRefList), self.getTempExpDatasetName(self.warpType)) if len(inputs.tempExpRefList) == 0: raise pipeBase.NoWorkFound("No coadd temporary exposures found") supplementaryData = self.makeSupplementaryDataGen3(butlerQC, inputRefs, outputRefs) retStruct = self.run(inputData['skyInfo'], inputs.tempExpRefList, inputs.imageScalerList, inputs.weightList, supplementaryData=supplementaryData) inputData.setdefault('brightObjectMask', None) self.processResults(retStruct.coaddExposure, inputData['brightObjectMask'], outputDataId) if self.config.doWrite: butlerQC.put(retStruct, outputRefs) return retStruct @timeMethod def runDataRef(self, dataRef, selectDataList=None, warpRefList=None):
Definition at line 532 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.supplementaryData |
Definition at line 549 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.tract |
Definition at line 382 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.visit |
Definition at line 383 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.warpRefList |
Definition at line 540 of file assembleCoadd.py.
lsst.pipe.tasks.assembleCoadd.warpType |
Definition at line 912 of file assembleCoadd.py.