GaudiMP.Parallel.Task Class Reference

Inheritance diagram for GaudiMP.Parallel.Task:

Collaboration diagram for GaudiMP.Parallel.Task:

Public Member Functions
	__new__ (cls, *args, **kwargs)
	initializeLocal (self)
	initializeRemote (self)
	process (self, item)
	finalize (self)

Public Attributes
	output = result

Protected Member Functions
	_mergeResults (self, result)
	_resetOutput (self)

Static Protected Attributes
bool	_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 66 of file Parallel.py.

Member Function Documentation

__new__()

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

Definition at line 73 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
 

_mergeResults()

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

protected

Definition at line 94 of file Parallel.py.

    def _mergeResults(self, result):
        if not isinstance(result, 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 isinstance(result, dict):
            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")
 

_resetOutput()

GaudiMP.Parallel.Task._resetOutput ( self )

protected

Definition at line 133 of file Parallel.py.

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

finalize()

GaudiMP.Parallel.Task.finalize

(

self

)

Definition at line 91 of file Parallel.py.

    def finalize(self):
        pass
 

initializeLocal()

GaudiMP.Parallel.Task.initializeLocal

(

self

)

Definition at line 82 of file Parallel.py.

    def initializeLocal(self):
        pass
 

initializeRemote()

GaudiMP.Parallel.Task.initializeRemote

(

self

)

Definition at line 85 of file Parallel.py.

    def initializeRemote(self):
        pass
 

process()

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

Definition at line 88 of file Parallel.py.

    def process(self, item):
        pass
 

Member Data Documentation

_initializeDone

bool GaudiMP.Parallel.Task._initializeDone = False

staticprotected

Definition at line 71 of file Parallel.py.

output

GaudiMP.Parallel.Task.output = result

Definition at line 95 of file Parallel.py.

---

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

• GaudiMP/python/GaudiMP/Parallel.py