PYME.ParallelTasks.distributor module

class PYME.ParallelTasks.distributor.CPDistributor

Bases: PYME.ParallelTasks.distributor.Distributor

Methods

announce(nodeID, ip, port)
handin(nodeID)
queues()
stop()
tasks([queue, nodeID, numWant, timeout])
announce(nodeID, ip, port)
handin(nodeID)
queues()
tasks(queue=None, nodeID=None, numWant=50, timeout=5)
class PYME.ParallelTasks.distributor.Distributor

Bases: object

Methods

stop()
stop()
class PYME.ParallelTasks.distributor.TaskInfo(task, timeout)

Bases: object

class PYME.ParallelTasks.distributor.TaskQueue(distributor)

Bases: object

Methods

handin(h)
info()
posttask(task)
stop()
handin(h)
info()
posttask(task)
stop()
class PYME.ParallelTasks.distributor.WFDistributor(port)

Bases: PYME.ParallelTasks.webframework.APIHTTPServer, PYME.ParallelTasks.distributor.Distributor

Attributes

timeout  

Methods

stop()
PYME.ParallelTasks.distributor.on_SIGHUP(signum, frame)
PYME.ParallelTasks.distributor.run(port)
PYME.ParallelTasks.distributor.runCP(port)