Herwig7Utils.ProcessHandler Class Reference

Class for handling parallel local multi-processing. More...

Collaboration diagram for Herwig7Utils.ProcessHandler:

Public Member Functions
	__init__ (self, process_list, logger)
	success (self)

Public Attributes
	processes = process_list
	n_initial = len(process_list)
	logger = logger

Detailed Description

Class for handling parallel local multi-processing.

Provides management functionality for waiting for a set of subprocesses to terminate and catch success/failure

Definition at line 46 of file Herwig7Utils.py.

Constructor & Destructor Documentation

__init__()

Herwig7Utils.ProcessHandler.__init__	(		self,
			process_list,
			logger )

Definition at line 48 of file Herwig7Utils.py.

  def __init__(self, process_list, logger):
    self.processes = process_list
    self.n_initial = len(process_list)
    self.logger = logger
 

Member Function Documentation

success()

Herwig7Utils.ProcessHandler.success

(

self

)

Definition at line 53 of file Herwig7Utils.py.

  def success(self):
    result = True
    while len(self.processes) > 0:
      for ID, process in enumerate(self.processes):
        returncode = process.poll()
        if returncode is not None:
 
          
          self.processes.remove(process)
          if returncode == 0:
            athMsgLog.info(ansi_format_info('Process #{} finished sucessfully, {}/{} still running'.format(process.ID, len(self.processes), self.n_initial)))
          elif returncode > 0:
            athMsgLog.error(ansi_format_error("Process #{} finished with error code {} (please check logfile '{}'), {}/{} still running".format(process.ID, returncode, process.logfile_title, len(self.processes), self.n_initial)))
            result = False
          elif returncode < 0:
            athMsgLog.error(ansi_format_error("Process #{} was terminated by signal {} (please check logfile '{}'), {}/{} still running".format(process.ID, -returncode, process.logfile_title, len(self.processes), self.n_initial)))
            result = False
 
          
          athMsgLog.info("Content of integration log file '%s':", process.logfile_title)
          athMsgLog.info("")
          with open(process.logfile_title, 'r') as logfile:
            for line in logfile:
              athMsgLog.info('  %s', line.rstrip('\n'))
          athMsgLog.info("")
          # self.logger.info('================================================================================')
          # self.logger.info("End of integration log file '{}'".format(process.logfile_title))
          # self.logger.info('================================================================================')
 
    return(result)
 
 

Member Data Documentation

logger

Herwig7Utils.ProcessHandler.logger = logger

Definition at line 51 of file Herwig7Utils.py.

n_initial

Herwig7Utils.ProcessHandler.n_initial = len(process_list)

Definition at line 50 of file Herwig7Utils.py.

processes

Herwig7Utils.ProcessHandler.processes = process_list

Definition at line 49 of file Herwig7Utils.py.

---

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

• Herwig7Utils.py