lsst.pipe.tasks.getRepositoryData.DataRefListRunner Class Reference

Inheritance diagram for lsst.pipe.tasks.getRepositoryData.DataRefListRunner:

Public Member Functions
def	__call__

Static Public Member Functions
def	getTargetList

Detailed Description

A task runner that calls run with a list of data references

Differs from the default TaskRunner by providing all data references at once,
instead of iterating over them one at a time.

Definition at line 38 of file getRepositoryData.py.

Member Function Documentation

def lsst.pipe.tasks.getRepositoryData.DataRefListRunner.__call__	(		self,
			dataRefList
	)

Run GetRepositoryDataTask.run on a single target

@param dataRefList: argument dict for run; contains one key: dataRefList

@return:
- None if doReturnResults false
- A pipe_base Struct containing these fields if doReturnResults true:
    - dataRefList: the argument dict sent to runDataRef
    - metadata: task metadata after execution of runDataRef
    - result: result returned by task runDataRef

Definition at line 50 of file getRepositoryData.py.

    def __call__(self, dataRefList):
        """Run GetRepositoryDataTask.run on a single target
        
        @param dataRefList: argument dict for run; contains one key: dataRefList

        @return:
        - None if doReturnResults false
        - A pipe_base Struct containing these fields if doReturnResults true:
            - dataRefList: the argument dict sent to runDataRef
            - metadata: task metadata after execution of runDataRef
            - result: result returned by task runDataRef
        """
        task = self.TaskClass(config=self.config, log=self.log)
        result = task.run(dataRefList)
        
        if self.doReturnResults:
            return pipeBase.Struct(
                dataRefList = dataRefList,
                metadata = task.metadata,
                result = result,
            )