GaudiMP.Parallel Namespace Reference

Classes
class	SshSession
class	Statistics
class	Task
class	WorkManager

Functions
def	_prefunction (f, task, item)
def	_ppfunction (args)

Variables
list	__all__ = ['Task', 'WorkManager']
list	excluded_varnames = ['HOSTNAME', 'SSH_CLIENT', 'SSH_CONNECTION', 'DISPLAY']

Function Documentation

def GaudiMP.Parallel._ppfunction (   args )

private

Definition at line 25 of file Parallel.py.

def _ppfunction(args):
    # --- Unpack arguments
    task, item = args
    stat = Statistics()
    # --- Initialize the remote side (at least once)
    if not task.__class__._initializeDone:
        for k, v in task.environ.items():
            if k not in excluded_varnames:
                os.environ[k] = v
        task.initializeRemote()
        task.__class__._initializeDone = True
    # --- Reset the task output
    task._resetOutput()
    # --- Call processing
    task.process(item)
    # --- Collect statistics
    stat.stop()
    return (copy.deepcopy(task.output), stat)

def GaudiMP.Parallel._prefunction (   f,   task,   item  )

private

Definition at line 21 of file Parallel.py.

def _prefunction(f, task, item):
    return f((task, item))

Variable Documentation

list GaudiMP.Parallel.__all__ = ['Task', 'WorkManager']

private

Definition at line 11 of file Parallel.py.

list GaudiMP.Parallel.excluded_varnames = ['HOSTNAME', 'SSH_CLIENT', 'SSH_CONNECTION', 'DISPLAY']

Definition at line 12 of file Parallel.py.