lsst.pipe.tasks.makeDiscreteSkyMap.MakeDiscreteSkyMapRunner Class Reference

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

Public Member Functions
def	__call__

Static Public Member Functions
def	getTargetList

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 64 of file makeDiscreteSkyMap.py.

Member Function Documentation

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 75 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
        if self.doRaise:
            result = task.run(butler, dataRefList)
        else:
            try:
                result = task.run(butler, dataRefList)
            except Exception, e:
                task.log.fatal("Failed: %s" % e)
                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,
            )