Commit 92e9fa21 authored by Samuel GAIST's avatar Samuel GAIST
Browse files

[scripts][worker] Use send_string for everything string related with zmq

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