From c7956abbe0e5267257e9687907f0074867bb3639 Mon Sep 17 00:00:00 2001
From: Philip ABBET <philip.abbet@idiap.ch>
Date: Mon, 9 Oct 2017 11:22:06 +0200
Subject: [PATCH] Small fix for the worker script
---
beat/core/worker.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/beat/core/worker.py b/beat/core/worker.py
index 0eb49818..cd9fdcb8 100755
--- a/beat/core/worker.py
+++ b/beat/core/worker.py
@@ -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
])
--
GitLab