PYME.ParallelTasks.nodeserver module

class PYME.ParallelTasks.nodeserver.CPNodeServer(distributor, ip_address, port, nodeID='DB3')

Bases: PYME.ParallelTasks.nodeserver.NodeServer

Attributes

num_tasks_to_request

Methods

handin(taskID, status)
rate()
status()
stop()
tasks(workerID[, numWant])
handin(taskID, status)
rate()
status()
tasks(workerID, numWant=50)
class PYME.ParallelTasks.nodeserver.NodeServer(distributor, ip_address, port, nodeID='DB3')

Bases: object

Attributes

num_tasks_to_request

Methods

stop()
num_tasks_to_request
stop()
class PYME.ParallelTasks.nodeserver.WFNodeServer(distributor, ip_address, port, nodeID='DB3')

Bases: PYME.ParallelTasks.webframework.APIHTTPServer, PYME.ParallelTasks.nodeserver.NodeServer

Attributes

num_tasks_to_request
timeout  

Methods

stop()
PYME.ParallelTasks.nodeserver.run(distributor, port)
PYME.ParallelTasks.nodeserver.runCP(distributor, port)