diff --git a/beat/core/scripts/worker.py b/beat/core/scripts/worker.py
index 277f8bd3d1a0873c3de6d8aa291c1494125470c8..115df896c5912e0bce0c76168fc3460a05d055c1 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):