From 54e2192dde97d2575f8953acfeb1906a1ae7a8fa Mon Sep 17 00:00:00 2001 From: Steven Robertson Date: Sun, 10 Jun 2012 09:14:25 -0700 Subject: [PATCH] Fix little output glitch --- dist/server.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dist/server.py b/dist/server.py index d01e755..b634e8e 100644 --- a/dist/server.py +++ b/dist/server.py @@ -72,12 +72,12 @@ def setup_worker_listener(addrs, tq, rq): worker_addr = readyq.get() wsock.send_multipart([worker_addr, '', pickle.dumps(ctask)]) - @spawn + @spawn def read_rsps(): while True: rsp = wsock.recv_multipart(copy=False) if rsp[2].bytes != '': - print '< ', ' '.join([r.bytes for r in rsp[1:-1]]) + print '< ', ' '.join([r.bytes for r in rsp[2:-1]]) rq.put(rsp[2:]) readyq.put(rsp[0])