IMP.parallel.Manager Class Reference

---

Detailed Description

Manages slaves and contexts.

Parameters:

python

If not None, the command to run to start a Python interpreter that can import the IMP module. Otherwise, the same interpreter that the master is currently using is used. This is passed to the shell, so a full command line (including multiple words separated by spaces) can be used if necessary.

host

The hostname that slaves use to connect back to the master. If not specified, the master machine's primary IP address is used. On multi-homed machines, such as compute cluster headnodes, this may need to be changed to allow all slaves to reach the master (typically the name of the machine's internal network address is needed). If only running local slaves, 'localhost' can be used to prohibit connections across the network.

Examples: local distance

List of all members.

Public Member Functions
def	add_slave
	Add a Slave object.
def	get_context
	Create and return a new Context in which tasks can be run.

Static Public Attributes
int	connect_timeout = 7200
int	heartbeat_timeout = 7200

---

Member Function Documentation

def IMP.parallel.Manager.add_slave	(		self,
			slave
	)

Add a Slave object.

def IMP.parallel.Manager.get_context	(		self,
			startup = None
	)

Create and return a new Context in which tasks can be run.

Parameters:

startup

If not None, a callable (Python function or class that implements the call method) that sets up the slave to run tasks. This method is only called once per slave. The return values from this method are passed to the task object when it runs on the slave.

---

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

• parallel/__init__.py