lsst.fgcmcal.fgcmOutputProducts.FgcmOutputProductsRunner Class Reference

Inheritance diagram for lsst.fgcmcal.fgcmOutputProducts.FgcmOutputProductsRunner:

Public Member Functions
def	__call__ (self, butler)
def	run (self, parsedCmd)

Static Public Member Functions
def	getTargetList (parsedCmd)

Detailed Description

Subclass of TaskRunner for fgcmOutputProductsTask

fgcmOutputProductsTask.run() takes one argument, the butler, and
does not run on any data in the repository.
This runner does not use any parallelization.

Definition at line 172 of file fgcmOutputProducts.py.

Member Function Documentation

__call__()

def lsst.fgcmcal.fgcmOutputProducts.FgcmOutputProductsRunner.__call__	(		self,
			butler
	)

Parameters
----------
butler: `lsst.daf.persistence.Butler`

Returns
-------
exitStatus: `list` with `pipeBase.Struct`
   exitStatus (0: success; 1: failure)
   if self.doReturnResults also
   results (`np.array` with absolute zeropoint offsets)

Definition at line 187 of file fgcmOutputProducts.py.

    def __call__(self, butler):
        """
        Parameters
        ----------
        butler: `lsst.daf.persistence.Butler`
 
        Returns
        -------
        exitStatus: `list` with `pipeBase.Struct`
           exitStatus (0: success; 1: failure)
           if self.doReturnResults also
           results (`np.array` with absolute zeropoint offsets)
        """
        task = self.TaskClass(butler=butler, config=self.config, log=self.log)
 
        exitStatus = 0
        if self.doRaise:
            results = task.runDataRef(butler)
        else:
            try:
                results = task.runDataRef(butler)
            except Exception as e:
                exitStatus = 1
                task.log.fatal("Failed: %s" % e)
                if not isinstance(e, pipeBase.TaskError):
                    traceback.print_exc(file=sys.stderr)
 
        task.writeMetadata(butler)
 
        if self.doReturnResults:
            # The results here are the zeropoint offsets for each band
            return [pipeBase.Struct(exitStatus=exitStatus,
                                    results=results)]
        else:
            return [pipeBase.Struct(exitStatus=exitStatus)]
 

getTargetList()

def lsst.fgcmcal.fgcmOutputProducts.FgcmOutputProductsRunner.getTargetList (   parsedCmd )

static

Return a list with one element, the butler.

Definition at line 181 of file fgcmOutputProducts.py.

    def getTargetList(parsedCmd):
        """
        Return a list with one element, the butler.
        """
        return [parsedCmd.butler]
 

run()

def lsst.fgcmcal.fgcmOutputProducts.FgcmOutputProductsRunner.run	(		self,
			parsedCmd
	)

Run the task, with no multiprocessing

Parameters
----------
parsedCmd: `lsst.pipe.base.ArgumentParser` parsed command line

Definition at line 223 of file fgcmOutputProducts.py.

    def run(self, parsedCmd):
        """
        Run the task, with no multiprocessing
 
        Parameters
        ----------
        parsedCmd: `lsst.pipe.base.ArgumentParser` parsed command line
        """
 
        resultList = []
 
        if self.precall(parsedCmd):
            targetList = self.getTargetList(parsedCmd)
            # make sure that we only get 1
            resultList = self(targetList[0])
 
        return resultList
 
 

---

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

• /j/snowflake/release/lsstsw/stack/0.1.5/Linux64/fgcmcal/21.0.0-4-g8a80011+f67daf2f53/python/lsst/fgcmcal/fgcmOutputProducts.py