From abb731b7a9c7d6071be88150adb31eeef7a0e9ec Mon Sep 17 00:00:00 2001
From: Philip ABBET <philip.abbet@idiap.ch>
Date: Fri, 20 Oct 2017 11:06:51 +0200
Subject: [PATCH] [scripts] worker.py: only send one READY message to the
scheduler
---
beat/core/scripts/worker.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/beat/core/scripts/worker.py b/beat/core/scripts/worker.py
index 277f8bd3..115df896 100755
--- a/beat/core/scripts/worker.py
+++ b/beat/core/scripts/worker.py
@@ -221,8 +221,10 @@ def main(user_input=None):
# Send READY messages until the scheduler acknowlege us
global stop
+ socket.send('rdy')
+ logger.info("Waiting for the scheduler...")
+
while not stop:
- socket.send('rdy')
socks = dict(poller.poll(100))
if not (socket in socks) or (socks[socket] != zmq.POLLIN):
--
GitLab