lsst.fgcmcal.fgcmFitCycle.FgcmFitCycleRunner Class Reference

Inheritance diagram for lsst.fgcmcal.fgcmFitCycle.FgcmFitCycleRunner:

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

Static Public Member Functions
def	getTargetList (parsedCmd)

Detailed Description

Subclass of TaskRunner for fgcmFitCycleTask

fgcmFitCycleTask.run() takes one argument, the butler, and uses
stars and visits previously extracted from dataRefs by
fgcmBuildStars.
This Runner does not perform any dataRef parallelization, but the FGCM
code called by the Task uses python multiprocessing (see the "ncores"
config option).

Definition at line 687 of file fgcmFitCycle.py.

Member Function Documentation

__call__()

def lsst.fgcmcal.fgcmFitCycle.FgcmFitCycleRunner.__call__	(		self,
			butler
	)

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

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

Definition at line 705 of file fgcmFitCycle.py.

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

getTargetList()

def lsst.fgcmcal.fgcmFitCycle.FgcmFitCycleRunner.getTargetList (   parsedCmd )

static

Return a list with one element, the butler.

Definition at line 699 of file fgcmFitCycle.py.

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

run()

def lsst.fgcmcal.fgcmFitCycle.FgcmFitCycleRunner.run	(		self,
			parsedCmd
	)

Run the task, with no multiprocessing

Parameters
----------
parsedCmd: ArgumentParser parsed command line

Definition at line 736 of file fgcmFitCycle.py.

    def run(self, parsedCmd):
        """
        Run the task, with no multiprocessing
 
        Parameters
        ----------
        parsedCmd: 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/fgcmFitCycle.py