GaudiMP.Parallel.Task Class Reference

Inheritance diagram for GaudiMP.Parallel.Task:

Collaboration diagram for GaudiMP.Parallel.Task:

Public Member Functions
def	__new__

def	initializeLocal

def	initializeRemote

def	process

def	finalize

Public Attributes
	output

Private Member Functions
def	_mergeResults

def	_resetOutput

Static Private Attributes
	_initializeDone False

Detailed Description

Basic base class to encapsulate any processing that is going to be porcessed in parallel.
    User class much inherit from it and implement the methods initializeLocal,
    initializeRemote, process and finalize.

Definition at line 47 of file Parallel.py.

Member Function Documentation

def GaudiMP.Parallel.Task.__new__	(	cls,
		args,
		kwargs
	)

Definition at line 52 of file Parallel.py.

 
     def __new__ ( cls, *args, **kwargs ):
         task = object.__new__( cls )
         task.output = ()
         task.environ = {}
         for k,v in os.environ.items(): task.environ[k] = v
         task.cwd = os.getcwd()
return task

def GaudiMP.Parallel.Task._mergeResults	(	self,
		result
	)

private

Definition at line 67 of file Parallel.py.

 
     def _mergeResults(self, result) :
         if type(result) is not type(self.output) :
             raise TypeError("output type is not same as obtained result")
         #--No iteratable---
         if not hasattr( result , '__iter__' ):
             if hasattr(self.output,'Add') : self.output.Add(result)
             elif hasattr(self.output,'__iadd__') : self.output += result
             elif hasattr(self.output,'__add__') : self.output = self.output + result
             else : raise TypeError('result cannot be added')
         #--Dictionary---
         elif type(result) is dict :
             if self.output.keys() <= result.keys(): minkeys = self.output.keys()
             else: minkeys = result.keys()
             for key in result.keys() :
                 if key in self.output :
                     if hasattr(self.output[key],'Add') : self.output[key].Add(result[key])
                     elif hasattr(self.output[key],'__iadd__') : self.output[key] += result[key]
                     elif hasattr(self.output[key],'__add__') : self.output[key] = self.output[key] + result[key]
                     else : raise TypeError('result cannot be added')
                 else :
                     self.output[key] = result[key]
         #--Anything else (list)
         else :
             for i in range( min( len(self.output) , len(result)) ):
                 if hasattr(self.output[i],'Add') : self.output[i].Add(result[i])
                 elif hasattr(self.output[i],'__iadd__') : self.output[i] += result[i]
                 elif hasattr(self.output[i],'__add__') : self.output[i] = self.output[i] + result[i]
else : raise TypeError('result cannot be added')

def GaudiMP.Parallel.Task._resetOutput ( self )

private

Definition at line 95 of file Parallel.py.

 
     def _resetOutput(self):
         output =  (type(self.output) is dict) and self.output.values() or self.output
         for o in output :
             if hasattr(o, 'Reset'): o.Reset()
 

Gaudi Framework, version v24r2

Public Member Functions

Public Attributes

Private Member Functions

Static Private Attributes

Detailed Description

Member Function Documentation

Member Data Documentation

def GaudiMP.Parallel.Task.process	(	self,
		item
	)