Commit 2903e928 authored by Samuel GAIST's avatar Samuel GAIST
Browse files

[tests][worker] Fix queue data creation

parent 6d9b35e2
......@@ -145,10 +145,10 @@ class ControllerProcess(multiprocessing.Process):
self.queue.put('STARTED')
def onWorkerReady(name):
self.queue.put('READY ' + name.decode('utf-8'))
self.queue.put('READY %s' % name)
def onWorkerGone(name):
self.queue.put('GONE ' + name.decode('utf-8'))
self.queue.put('GONE %s' % name)
self.controller = WorkerController(
'127.0.0.1',
......
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