eta.core.eta.ProcessManager

class ProcessManager(address=None, authkey=None, serializer='pickle', ctx=None)[source]

Bases: BaseManager

Manager to handle multiprocessing.

Methods

connect

Connect manager object to the server process

get_server

Return server object with serve_forever() method and address attribute

join

Join the manager process (if it has been spawned)

register

Register a typeid with the manager type

start

Spawn a server process for this manager object

Attributes

address

connect()

Connect manager object to the server process

get_server()

Return server object with serve_forever() method and address attribute

join(timeout=None)

Join the manager process (if it has been spawned)

classmethod register(typeid, callable=None, proxytype=None, exposed=None, method_to_typeid=None, create_method=True)

Register a typeid with the manager type

start(initializer=None, initargs=())

Spawn a server process for this manager object