LSST Applications  21.0.0-172-gfb10e10a+18fedfabac,22.0.0+297cba6710,22.0.0+80564b0ff1,22.0.0+8d77f4f51a,22.0.0+a28f4c53b1,22.0.0+dcf3732eb2,22.0.1-1-g7d6de66+2a20fdde0d,22.0.1-1-g8e32f31+297cba6710,22.0.1-1-geca5380+7fa3b7d9b6,22.0.1-12-g44dc1dc+2a20fdde0d,22.0.1-15-g6a90155+515f58c32b,22.0.1-16-g9282f48+790f5f2caa,22.0.1-2-g92698f7+dcf3732eb2,22.0.1-2-ga9b0f51+7fa3b7d9b6,22.0.1-2-gd1925c9+bf4f0e694f,22.0.1-24-g1ad7a390+a9625a72a8,22.0.1-25-g5bf6245+3ad8ecd50b,22.0.1-25-gb120d7b+8b5510f75f,22.0.1-27-g97737f7+2a20fdde0d,22.0.1-32-gf62ce7b1+aa4237961e,22.0.1-4-g0b3f228+2a20fdde0d,22.0.1-4-g243d05b+871c1b8305,22.0.1-4-g3a563be+32dcf1063f,22.0.1-4-g44f2e3d+9e4ab0f4fa,22.0.1-42-gca6935d93+ba5e5ca3eb,22.0.1-5-g15c806e+85460ae5f3,22.0.1-5-g58711c4+611d128589,22.0.1-5-g75bb458+99c117b92f,22.0.1-6-g1c63a23+7fa3b7d9b6,22.0.1-6-g50866e6+84ff5a128b,22.0.1-6-g8d3140d+720564cf76,22.0.1-6-gd805d02+cc5644f571,22.0.1-8-ge5750ce+85460ae5f3,master-g6e05de7fdc+babf819c66,master-g99da0e417a+8d77f4f51a,w.2021.48
LSST Data Management Base Package
Public Member Functions | Public Attributes | List of all members
lsst.pipe.drivers.processCcdWithFakesDriver.ProcessCcdWithFakesTaskRunner Class Reference
Inheritance diagram for lsst.pipe.drivers.processCcdWithFakesDriver.ProcessCcdWithFakesTaskRunner:
lsst.ctrl.pool.parallel.BatchTaskRunner

Public Member Functions

def run (self, parsedCmd)
 
def __call__ (self, cache, args)
 

Public Attributes

 numProcesses
 

Detailed Description

Run batches, and initialize Task

Definition at line 27 of file processCcdWithFakesDriver.py.

Member Function Documentation

◆ __call__()

def lsst.ctrl.pool.parallel.BatchTaskRunner.__call__ (   self,
  cache,
  args 
)
inherited
Run the Task on a single target

Strips out the process pool 'cache' argument.

'args' are those arguments provided by the getTargetList method.

Brings down the entire job if an exception is not caught (i.e., --doraise).

Definition at line 583 of file parallel.py.

583  def __call__(self, cache, args):
584  """Run the Task on a single target
585 
586  Strips out the process pool 'cache' argument.
587 
588  'args' are those arguments provided by the getTargetList method.
589 
590  Brings down the entire job if an exception is not caught (i.e., --doraise).
591  """
592  return TaskRunner.__call__(self, args)
593 
594 

◆ run()

def lsst.ctrl.pool.parallel.BatchTaskRunner.run (   self,
  parsedCmd 
)
inherited
Run the task on all targets

Sole input is the result of parsing the command-line with the ArgumentParser.

Output is None if 'precall' failed; otherwise it is a list of calling ourself
on each element of the target list from the 'getTargetList' method.

Definition at line 555 of file parallel.py.

555  def run(self, parsedCmd):
556  """Run the task on all targets
557 
558  Sole input is the result of parsing the command-line with the ArgumentParser.
559 
560  Output is None if 'precall' failed; otherwise it is a list of calling ourself
561  on each element of the target list from the 'getTargetList' method.
562  """
563  resultList = None
564 
565  self.prepareForMultiProcessing()
566  pool = Pool()
567 
568  if self.precall(parsedCmd):
569  targetList = self.getTargetList(parsedCmd)
570  if len(targetList) > 0:
571  parsedCmd.log.info("Processing %d targets with a pool of %d processes..." %
572  (len(targetList), pool.size))
573  # Run the task using self.__call__
574  resultList = pool.map(self, targetList)
575  else:
576  parsedCmd.log.warn("Not running the task because there is no data to process; "
577  "you may preview data using \"--show data\"")
578  resultList = []
579 
580  return resultList
581 
def run(self, coaddExposures, bbox, wcs)
Definition: getTemplate.py:603

Member Data Documentation

◆ numProcesses

lsst.ctrl.pool.parallel.BatchTaskRunner.numProcesses
inherited

Definition at line 553 of file parallel.py.


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