Initial version of system command out/err forwarding.

IPython/zmq/zmqshell.py

@@ -0,0 +1,20 b''
+import sys
+from subprocess import Popen, PIPE
+from IPython.core.interactiveshell import InteractiveShell, InteractiveShellABC
+
+
+class ZMQInteractiveShell(InteractiveShell):
+    """A subclass of InteractiveShell for ZMQ."""
+
+    def system(self, cmd):
+        cmd = self.var_expand(cmd, depth=2)
+        p = Popen(cmd, shell=True, stdout=PIPE, stderr=PIPE)
+        for line in p.stdout.read().split('\n'):
+            if len(line) > 0:
+                print line
+        for line in p.stderr.read().split('\n'):
+            if len(line) > 0:
+                print line
+        return p.wait()
+
+InteractiveShellABC.register(ZMQInteractiveShell)

IPython/zmq/ipkernel.py

@@ -27,7 +27,7 b' import zmq'
 
 # Local imports.
 from IPython.config.configurable import Configurable
-from IPython.core.interactiveshell import InteractiveShell, InteractiveShellABC
+from IPython.zmq.zmqshell import ZMQInteractiveShell
 from IPython.external.argparse import ArgumentParser
 from IPython.utils.traitlets import Instance
 from IPython.zmq.session import Session, Message
@@ -50,7 +50,7 b' class Kernel(Configurable):'
 
     def __init__(self, **kwargs):
         super(Kernel, self).__init__(**kwargs)
-        self.shell = InteractiveShell.instance()
+        self.shell = ZMQInteractiveShell.instance()
         
         # Build dict of handlers for message types
         msg_types = [ 'execute_request', 'complete_request',