Commit abb731b7 authored by Philip ABBET's avatar Philip ABBET
Browse files

[scripts] worker.py: only send one READY message to the scheduler

parent a1314e17
......@@ -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):
......
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