FgcmFitCycleRunner

class lsst.fgcmcal.FgcmFitCycleRunner(TaskClass, parsedCmd, doReturnResults=False)

Bases: lsst.pipe.base.ButlerInitializedTaskRunner

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).

Attributes Summary

TIMEOUT

Methods Summary

__call__(butler)	Parameters:
getTargetList(parsedCmd)	Return a list with one element, the butler.
makeTask([parsedCmd, args])	A variant of the base version that passes a butler argument to the task’s constructor.
precall(parsedCmd)	Hook for code that should run exactly once, before multiprocessing.
prepareForMultiProcessing()	Prepare this instance for multiprocessing
run(parsedCmd)	Run the task, with no multiprocessing
runTask(task, dataRef, kwargs)	Make the actual call to runDataRef for this task.

Attributes Documentation

TIMEOUT = 2592000

Methods Documentation

__call__(butler)

Parameters:

butler: `lsst.daf.persistence.Butler`

Returns:

exitStatus: `list` with `pipeBase.Struct`

exitStatus (0: success; 1: failure)

static getTargetList(parsedCmd)

Return a list with one element, the butler.

makeTask(parsedCmd=None, args=None)

A variant of the base version that passes a butler argument to the task’s constructor.

Parameters:

parsedCmd : argparse.Namespace

Parsed command-line options, as returned by the ArgumentParser; if specified then args is ignored.

args

Other arguments; if parsedCmd is None then this must be specified.

Raises:

RuntimeError

Raised if parsedCmd and args are both None.

precall(parsedCmd)

Hook for code that should run exactly once, before multiprocessing.

Notes

Must return True if TaskRunner.__call__ should subsequently be called.

Warning

Implementations must take care to ensure that no unpicklable attributes are added to the TaskRunner itself, for compatibility with multiprocessing.

The default implementation writes package versions, schemas and configs, or compares them to existing files on disk if present.

prepareForMultiProcessing()

Prepare this instance for multiprocessing

Optional non-picklable elements are removed.

This is only called if the task is run under multiprocessing.

run(parsedCmd)

Run the task, with no multiprocessing

Parameters:

parsedCmd: ArgumentParser parsed command line

runTask(task, dataRef, kwargs)

Make the actual call to runDataRef for this task.

Parameters:

task : lsst.pipe.base.CmdLineTask class

The class of the task to run.

dataRef

Butler data reference that contains the data the task will process.

kwargs

Any additional keyword arguments. See TaskRunner.getTargetList above.

Notes

The default implementation of TaskRunner.runTask works for any command-line task which has a runDataRef method that takes a data reference and an optional set of additional keyword arguments. This method returns the results generated by the task’s runDataRef method.