Commit c7956abb authored by Philip ABBET's avatar Philip ABBET

Small fix for the worker script

parent 0c1899a5
......@@ -86,7 +86,7 @@ class WorkerController(object):
def execute(self, worker, job_id, configuration):
self.socket.send_multipart([
worker,
str(worker),
WorkerController.EXECUTE,
str(job_id),
simplejson.dumps(configuration)
......@@ -95,14 +95,14 @@ class WorkerController(object):
def cancel(self, worker):
self.socket.send_multipart([
worker,
str(worker),
WorkerController.CANCEL
])
def ack(self, worker):
self.socket.send_multipart([
worker,
str(worker),
WorkerController.ACK
])
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment