lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask Class Reference

Inheritance diagram for lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask:

Public Member Functions
	__init__ (self, initInputs=None, **kwargs)
	runQuantum (self, butlerQC, inputRefs, outputRefs)

Public Attributes
	sourceSchema

Static Public Attributes
	ConfigClass = FgcmCalibrateTractTableConfig
bool	canMultiprocess = False

Static Protected Attributes
str	_DefaultName = "fgcmCalibrateTractTable"

Detailed Description

Calibrate a single tract using fgcmcal, using sourceTable_visit (parquet)
input catalogs.

Definition at line 153 of file fgcmCalibrateTractTable.py.

Constructor & Destructor Documentation

__init__()

lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask.__init__	(		self,
			initInputs = None,
		**	kwargs )

Reimplemented from lsst.fgcmcal.fgcmCalibrateTractBase.FgcmCalibrateTractBaseTask.

Definition at line 163 of file fgcmCalibrateTractTable.py.

    def __init__(self, initInputs=None, **kwargs):
        super().__init__(initInputs=initInputs, **kwargs)
        if initInputs is not None:
            self.sourceSchema = initInputs["sourceSchema"].schema
 

Member Function Documentation

runQuantum()

lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask.runQuantum	(		self,
			butlerQC,
			inputRefs,
			outputRefs )

Definition at line 168 of file fgcmCalibrateTractTable.py.

    def runQuantum(self, butlerQC, inputRefs, outputRefs):
        handleDict = butlerQC.get(inputRefs)
 
        self.log.info("Running with %d sourceTable_visit handles", (len(handleDict['source_catalogs'])))
 
        # Run the build stars tasks
        tract = butlerQC.quantum.dataId['tract']
 
        handleDict['sourceSchema'] = self.sourceSchema
 
        sourceTableHandles = handleDict['source_catalogs']
        sourceTableHandleDict = {sourceTableHandle.dataId['visit']: sourceTableHandle for
                                 sourceTableHandle in sourceTableHandles}
 
        visitSummaryHandles = handleDict['visitSummary']
        visitSummaryHandleDict = {visitSummaryHandle.dataId['visit']: visitSummaryHandle for
                                  visitSummaryHandle in visitSummaryHandles}
 
        handleDict['sourceTableHandleDict'] = sourceTableHandleDict
        handleDict['visitSummaryHandleDict'] = visitSummaryHandleDict
 
        # And the outputs
        if self.config.fgcmOutputProducts.doZeropointOutput:
            photoCalibRefDict = {photoCalibRef.dataId['visit']:
                                 photoCalibRef for photoCalibRef in outputRefs.fgcmPhotoCalib}
            handleDict['fgcmPhotoCalibs'] = photoCalibRefDict
 
        if self.config.fgcmOutputProducts.doAtmosphereOutput:
            atmRefDict = {atmRef.dataId['visit']: atmRef for
                          atmRef in outputRefs.fgcmTransmissionAtmosphere}
            handleDict['fgcmTransmissionAtmospheres'] = atmRefDict
 
        if self.config.fgcmBuildStars.doReferenceMatches:
            refConfig = LoadReferenceObjectsConfig()
            refConfig.filterMap = self.config.fgcmBuildStars.fgcmLoadReferenceCatalog.filterMap
            loader = ReferenceObjectLoader(dataIds=[ref.datasetRef.dataId
                                                    for ref in inputRefs.refCat],
                                           refCats=butlerQC.get(inputRefs.refCat),
                                           name=self.config.connections.refCat,
                                           config=refConfig,
                                           log=self.log)
            buildStarsRefObjLoader = loader
        else:
            buildStarsRefObjLoader = None
 
        if self.config.fgcmOutputProducts.doReferenceCalibration:
            refConfig = self.config.fgcmOutputProducts.refObjLoader
            loader = ReferenceObjectLoader(dataIds=[ref.datasetRef.dataId
                                                    for ref in inputRefs.refCat],
                                           refCats=butlerQC.get(inputRefs.refCat),
                                           name=self.config.connections.refCat,
                                           config=refConfig,
                                           log=self.log)
            self.fgcmOutputProducts.refObjLoader = loader
 
        struct = self.run(handleDict, tract,
                          buildStarsRefObjLoader=buildStarsRefObjLoader)
 
        if struct.photoCalibCatalogs is not None:
            self.log.info("Outputting photoCalib catalogs.")
            for visit, expCatalog in struct.photoCalibCatalogs:
                butlerQC.put(expCatalog, photoCalibRefDict[visit])
            self.log.info("Done outputting photoCalib catalogs.")
 
        if struct.atmospheres is not None:
            self.log.info("Outputting atmosphere transmission files.")
            for visit, atm in struct.atmospheres:
                butlerQC.put(atm, atmRefDict[visit])
            self.log.info("Done outputting atmosphere files.")
 
        # Turn raw repeatability into simple catalog for persistence
        schema = afwTable.Schema()
        schema.addField('rawRepeatability', type=np.float64,
                        doc="Per-band raw repeatability in FGCM calibration.")
        repeatabilityCat = afwTable.BaseCatalog(schema)
        repeatabilityCat.resize(len(struct.repeatability))
        repeatabilityCat['rawRepeatability'][:] = struct.repeatability
 
        butlerQC.put(repeatabilityCat, outputRefs.fgcmRepeatability)
 
        return

Member Data Documentation

_DefaultName

str lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask._DefaultName = "fgcmCalibrateTractTable"

staticprotected

Definition at line 159 of file fgcmCalibrateTractTable.py.

canMultiprocess

bool lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask.canMultiprocess = False

static

Definition at line 161 of file fgcmCalibrateTractTable.py.

ConfigClass

lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask.ConfigClass = FgcmCalibrateTractTableConfig

static

Definition at line 158 of file fgcmCalibrateTractTable.py.

sourceSchema

lsst.fgcmcal.fgcmCalibrateTractTable.FgcmCalibrateTractTableTask.sourceSchema

Definition at line 166 of file fgcmCalibrateTractTable.py.

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-8.0.0/Linux64/fgcmcal/g487adcacf7+71499e7cba/python/lsst/fgcmcal/fgcmCalibrateTractTable.py