lsst.fgcmcal.fgcmBuildStarsBase.FgcmBuildStarsRunner Class Reference

Inheritance diagram for lsst.fgcmcal.fgcmBuildStarsBase.FgcmBuildStarsRunner:

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

Static Public Member Functions
def	getTargetList (parsedCmd)

Detailed Description

Subclass of TaskRunner for FgcmBuildStars tasks

fgcmBuildStarsTask.run() and fgcmBuildStarsTableTask.run() take a number of
arguments, one of which is the butler (for persistence and mapper data),
and a list of dataRefs extracted from the command line.  Note that FGCM
runs on a large set of dataRefs, and not on single dataRef/tract/patch.
This class transforms the process arguments generated by the ArgumentParser
into the arguments expected by FgcmBuildStarsTask.run().  This runner does
not use any parallelization.

Definition at line 206 of file fgcmBuildStarsBase.py.

Member Function Documentation

__call__()

def lsst.fgcmcal.fgcmBuildStarsBase.FgcmBuildStarsRunner.__call__	(		self,
			args
	)

Parameters
----------
args: `tuple` with (butler, dataRefList)

Returns
-------
exitStatus: `list` with `lsst.pipe.base.Struct`
   exitStatus (0: success; 1: failure)

Definition at line 226 of file fgcmBuildStarsBase.py.

    def __call__(self, args):
        """
        Parameters
        ----------
        args: `tuple` with (butler, dataRefList)
 
        Returns
        -------
        exitStatus: `list` with `lsst.pipe.base.Struct`
           exitStatus (0: success; 1: failure)
        """
        butler, dataRefList = args
 
        task = self.TaskClass(config=self.config, log=self.log)
 
        exitStatus = 0
        if self.doRaise:
            task.runDataRef(butler, dataRefList)
        else:
            try:
                task.runDataRef(butler, dataRefList)
            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)
 
        # The task does not return any results:
        return [pipeBase.Struct(exitStatus=exitStatus)]
 

getTargetList()

def lsst.fgcmcal.fgcmBuildStarsBase.FgcmBuildStarsRunner.getTargetList (   parsedCmd )

static

Return a list with one element: a tuple with the butler and
list of dataRefs

Definition at line 218 of file fgcmBuildStarsBase.py.

    def getTargetList(parsedCmd):
        """
        Return a list with one element: a tuple with the butler and
        list of dataRefs
        """
        # we want to combine the butler with any (or no!) dataRefs
        return [(parsedCmd.butler, parsedCmd.id.refList)]
 

run()

def lsst.fgcmcal.fgcmBuildStarsBase.FgcmBuildStarsRunner.run	(		self,
			parsedCmd
	)

Run the task, with no multiprocessing

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

Definition at line 258 of file fgcmBuildStarsBase.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)
            resultList = self(targetList[0])
 
        return resultList
 
 

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/fgcmcal/22.0.1-15-g6a90155+515f58c32b/python/lsst/fgcmcal/fgcmBuildStarsBase.py