Classes
class	SshSession

class	Statistics

class	Task

class	WorkManager

Functions
	_prefunction (f, task, item)

	_ppfunction (args)

Variables
list	__all__ = ["Task", "WorkManager"]
	(c) Copyright 1998-2023 CERN for the benefit of the LHCb and ATLAS collaborations # # This software is distributed under the terms of the Apache version 2 licence, # copied verbatim in the file "LICENSE".

list	excluded_varnames = ["HOSTNAME", "SSH_CLIENT", "SSH_CONNECTION", "DISPLAY"]

Function Documentation

◆ _ppfunction()

GaudiMP.Parallel._ppfunction ( args )

protected

Definition at line 35 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)
 
 

◆ _prefunction()

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

protected

Definition at line 31 of file Parallel.py.

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

Variable Documentation

◆ all

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

private

(c) Copyright 1998-2023 CERN for the benefit of the LHCb and ATLAS collaborations # # This software is distributed under the terms of the Apache version 2 licence, # copied verbatim in the file "LICENSE".

# # In applying this licence, CERN does not waive the privileges and immunities # granted to it by virtue of its status as an Intergovernmental Organization # or submit itself to any jurisdiction. #

File: GaudiMP/Parallel.py Author: Pere Mato (pere..nosp@m.mato.nosp@m.@cern.nosp@m..ch)

Definition at line 21 of file Parallel.py.

◆ excluded_varnames

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

Definition at line 22 of file Parallel.py.

Classes

Functions