From 1f78d0e2be5f8056017f5c8f7601167e5e74d9d1 2011-06-30 22:05:55 From: MinRK Date: 2011-06-30 22:05:55 Subject: [PATCH] fix typo in StreamKernel.abort_queue abort_queue had not been updated to match return value of session.send(), which is the message itself, and no longer a tuple. --- diff --git a/IPython/parallel/engine/streamkernel.py b/IPython/parallel/engine/streamkernel.py index 434ea58..1df2d26 100755 --- a/IPython/parallel/engine/streamkernel.py +++ b/IPython/parallel/engine/streamkernel.py @@ -150,7 +150,7 @@ class Kernel(SessionFactory): # self.reply_socket.send(ident,zmq.SNDMORE) # self.reply_socket.send_json(reply_msg) reply_msg = self.session.send(stream, reply_type, - content={'status' : 'aborted'}, parent=msg, ident=idents)[0] + content={'status' : 'aborted'}, parent=msg, ident=idents) self.log.debug(str(reply_msg)) # We need to wait a bit for requests to come in. This can probably # be set shorter for true asynchronous clients.