Commit dc7d9b72 authored by Samuel GAIST's avatar Samuel GAIST
Browse files

[scripts][worker] Use WorkController constants and use send as they are bytes now

parent 2c7dddbb
...@@ -150,7 +150,7 @@ def connect_to_scheduler(address, name): ...@@ -150,7 +150,7 @@ def connect_to_scheduler(address, name):
poller.register(socket, zmq.POLLIN) poller.register(socket, zmq.POLLIN)
# Tell the scheduler we are ready # Tell the scheduler we are ready
socket.send_string('rdy') socket.send(WorkerController.READY)
# Wait for a response from the scheduler # Wait for a response from the scheduler
logger.info("Waiting for the scheduler...") logger.info("Waiting for the scheduler...")
...@@ -419,7 +419,7 @@ def main(user_input=None): ...@@ -419,7 +419,7 @@ def main(user_input=None):
if socket: if socket:
socket.send_string(WorkerController.EXIT) socket.send(WorkerController.EXIT)
# Cleanup # Cleanup
......
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