upstream/ipython Files · IPython/zmq/zmqshell.py

Changing how IPython.utils.io.Term is handled....

Changing how IPython.utils.io.Term is handled. We used to create a module level IOTerm instance called IPython.utils.io.Term when IPython.utils.io was imported. We now delay this until InteractiveShell.init_io is called. This gives us a chance to override sys.stdout/sys.stderr first. All code that uses IPython.utils.io.Term must refer to by its full name: "IPython.utils.io.Term" and not hold references to it.

Brian Granger - - Load All Authors

File last commit:

r2775:c291d5fa


                r2775:c291d5fa

Download file

             zmqshell.py
        
                    31 lines
            
             | 1.1 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / IPython / zmq / zmqshell.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      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)

              sys.stdout.flush()

              sys.stderr.flush()

              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()

          def init_io(self):

              # This will just use sys.stdout and sys.stderr. If you want to

              # override sys.stdout and sys.stderr themselves, you need to do that

              # *before* instantiating this class, because Term holds onto 

              # references to the underlying streams.

              import IPython.utils.io

              Term = IPython.utils.io.IOTerm()

              IPython.utils.io.Term = Term

      InteractiveShellABC.register(ZMQInteractiveShell)

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				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)
				sys.stdout.flush()
				sys.stderr.flush()
				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()

				def init_io(self):
				# This will just use sys.stdout and sys.stderr. If you want to
				# override sys.stdout and sys.stderr themselves, you need to do that
				# before instantiating this class, because Term holds onto
				# references to the underlying streams.
				import IPython.utils.io
				Term = IPython.utils.io.IOTerm()
				IPython.utils.io.Term = Term

				InteractiveShellABC.register(ZMQInteractiveShell)