lsst.pipe.tasks.makeDiscreteSkyMap.MakeDiscreteSkyMapRunner Class Reference

Inheritance diagram for lsst.pipe.tasks.makeDiscreteSkyMap.MakeDiscreteSkyMapRunner:

Public Member Functions
def	__call__ (self, args)

Static Public Member Functions
def	getTargetList (parsedCmd)

Detailed Description

Run a task with all dataRefs at once, rather than one dataRef at a time.

Call the run method of the task using two positional arguments:
- butler: data butler
- dataRefList: list of all dataRefs,

Definition at line 66 of file makeDiscreteSkyMap.py.

Member Function Documentation

__call__()

def lsst.pipe.tasks.makeDiscreteSkyMap.MakeDiscreteSkyMapRunner.__call__	(		self,
			args
	)

@param args     Arguments for Task.run()

@return:
- None if self.doReturnResults false
- A pipe_base Struct containing these fields if self.doReturnResults true:
    - dataRef: the provided data reference
    - metadata: task metadata after execution of run
    - result: result returned by task run, or None if the task fails

Definition at line 77 of file makeDiscreteSkyMap.py.

    def __call__(self, args):
        """
        @param args     Arguments for Task.run()
 
        @return:
        - None if self.doReturnResults false
        - A pipe_base Struct containing these fields if self.doReturnResults true:
            - dataRef: the provided data reference
            - metadata: task metadata after execution of run
            - result: result returned by task run, or None if the task fails
        """
        butler, dataRefList = args
        task = self.TaskClass(config=self.config, log=self.log)
        result = None  # in case the task fails
        exitStatus = 0  # exit status for shell
        if self.doRaise:
            result = task.runDataRef(butler, dataRefList)
        else:
            try:
                result = task.runDataRef(butler, dataRefList)
            except Exception as e:
                task.log.fatal("Failed: %s", e)
                exitStatus = 1
                if not isinstance(e, pipeBase.TaskError):
                    traceback.print_exc(file=sys.stderr)
        for dataRef in dataRefList:
            task.writeMetadata(dataRef)
 
        if self.doReturnResults:
            return pipeBase.Struct(
                dataRefList=dataRefList,
                metadata=task.metadata,
                result=result,
                exitStatus=exitStatus,
            )
        else:
            return pipeBase.Struct(
                exitStatus=exitStatus,
            )
 
 

getTargetList()

def lsst.pipe.tasks.makeDiscreteSkyMap.MakeDiscreteSkyMapRunner.getTargetList (   parsedCmd )

static

Definition at line 74 of file makeDiscreteSkyMap.py.

    def getTargetList(parsedCmd):
        return [(parsedCmd.butler, parsedCmd.id.refList)]
 

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/pipe_tasks/21.0.0-172-gfb10e10a+18fedfabac/python/lsst/pipe/tasks/makeDiscreteSkyMap.py