Fixing another bug in msg_type refactoring.

ellisonbg · Jul 14, 2011 · 260396c · 260396c
1 parent c4eb828
commit 260396c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/IPython/parallel/engine/streamkernel.py b/IPython/parallel/engine/streamkernel.py
@@ -384,7 +384,7 @@ def dispatch_queue(self, stream, msg):
 
         header = msg['header']
         msg_id = header['msg_id']
-        msg['header']['msg_type']
+        msg_type = msg['header']['msg_type']
         if self.check_aborted(msg_id):
             self.aborted.remove(msg_id)
             # is it safe to assume a msg_id will not be resubmitted?