remove ipython_kernel.zmq sub-pkg

IPython/kernel/__init__.py

@@ -13,16 +13,18 b' warn("The `IPython.kernel` package has been deprecated. "'
 
 from IPython.utils.shimmodule import ShimModule
 
-# session moved relative to top-level
+# zmq subdir is gone
 sys.modules['IPython.kernel.zmq.session'] = ShimModule('session', mirror='jupyter_client.session')
+sys.modules['IPython.kernel.zmq'] = ShimModule('zmq', mirror='ipython_kernel')
 
-for pkg in ('comm', 'inprocess', 'resources', 'zmq'):
+for pkg in ('comm', 'inprocess', 'resources'):
     sys.modules['IPython.kernel.%s' % pkg] = ShimModule(pkg, mirror='ipython_kernel.%s' % pkg)
+
 for pkg in ('ioloop', 'blocking'):
     sys.modules['IPython.kernel.%s' % pkg] = ShimModule(pkg, mirror='jupyter_client.%s' % pkg)
 
 # required for `from IPython.kernel import PKG`
-from ipython_kernel import comm, inprocess, resources, zmq
+from ipython_kernel import comm, inprocess, resources
 from jupyter_client import ioloop, blocking
 # public API
 from ipython_kernel.connect import *

IPython/testing/iptest.py

@@ -232,10 +232,10 b" sec.requires('zmq')"
 # The in-process kernel tests are done in a separate section
 sec.exclude('inprocess')
 # importing gtk sets the default encoding, which we want to avoid
-sec.exclude('zmq.gui.gtkembed')
-sec.exclude('zmq.gui.gtk3embed')
+sec.exclude('gui.gtkembed')
+sec.exclude('gui.gtk3embed')
 if not have['matplotlib']:
-    sec.exclude('zmq.pylab')
+    sec.exclude('pylab')
 
 # kernel.inprocess:
 test_sections['kernel.inprocess'].requires('zmq')

ipython_kernel/__main__.py

@@ -1,3 +1,3 b''
 if __name__ == '__main__':
-    from ipython_kernel.zmq import kernelapp as app
+    from ipython_kernel import kernelapp as app
     app.launch_new_instance()

ipython_kernel/comm/comm.py

@@ -9,7 +9,7 b' import uuid'
 from zmq.eventloop.ioloop import IOLoop
 
 from IPython.config import LoggingConfigurable
-from ipython_kernel.zmq.kernelbase import Kernel
+from ipython_kernel.kernelbase import Kernel
 
 from IPython.utils.jsonutil import json_clean
 from IPython.utils.traitlets import Instance, Unicode, Bytes, Bool, Dict, Any
@@ -20,7 +20,7 b' class Comm(LoggingConfigurable):'
     # If this is instantiated by a non-IPython kernel, shell will be None
     shell = Instance('IPython.core.interactiveshell.InteractiveShellABC',
                      allow_none=True)
-    kernel = Instance('ipython_kernel.zmq.kernelbase.Kernel')
+    kernel = Instance('ipython_kernel.kernelbase.Kernel')
     def _kernel_default(self):
         if Kernel.initialized():
             return Kernel.instance()
@@ -28,7 +28,7 b' class Comm(LoggingConfigurable):'
     iopub_socket = Any()
     def _iopub_socket_default(self):
         return self.kernel.iopub_socket
-    session = Instance('ipython_kernel.zmq.session.Session')
+    session = Instance('ipython_kernel.session.Session')
     def _session_default(self):
         if self.kernel is not None:
             return self.kernel.session

ipython_kernel/comm/manager.py

@@ -31,12 +31,12 b' class CommManager(LoggingConfigurable):'
     # If this is instantiated by a non-IPython kernel, shell will be None
     shell = Instance('IPython.core.interactiveshell.InteractiveShellABC',
                      allow_none=True)
-    kernel = Instance('ipython_kernel.zmq.kernelbase.Kernel')
+    kernel = Instance('ipython_kernel.kernelbase.Kernel')
 
     iopub_socket = Any()
     def _iopub_socket_default(self):
         return self.kernel.iopub_socket
-    session = Instance('ipython_kernel.zmq.session.Session')
+    session = Instance('ipython_kernel.session.Session')
     def _session_default(self):
         return self.kernel.session
 

ipython_kernel/datapub.py

@@ -16,8 +16,8 b' from IPython.config import Configurable'
 from ipython_kernel.inprocess.socket import SocketABC
 from IPython.utils.jsonutil import json_clean
 from IPython.utils.traitlets import Instance, Dict, CBytes
-from ipython_kernel.zmq.serialize import serialize_object
-from ipython_kernel.zmq.session import Session, extract_header
+from ipython_kernel.serialize import serialize_object
+from ipython_kernel.session import Session, extract_header
 
 #-----------------------------------------------------------------------------
 # Code
@@ -66,5 +66,5 b' def publish_data(data):'
     data : dict
         The data to be published. Think of it as a namespace.
     """
-    from ipython_kernel.zmq.zmqshell import ZMQInteractiveShell
+    from ipython_kernel.zmqshell import ZMQInteractiveShell
     ZMQInteractiveShell.instance().data_pub.publish_data(data)

ipython_kernel/eventloops.py

@@ -49,7 +49,7 b' def register_integration(*toolkitnames):'
     instance, arrange for the event loop to call ``kernel.do_one_iteration()``
     at least every ``kernel._poll_interval`` seconds, and start the event loop.
 
-    :mod:`ipython_kernel.zmq.eventloops` provides and registers such functions
+    :mod:`ipython_kernel.eventloops` provides and registers such functions
     for a few common event loops.
     """
     def decorator(func):

ipython_kernel/inprocess/ipkernel.py

@@ -10,8 +10,8 b' import sys'
 from IPython.core.interactiveshell import InteractiveShellABC
 from IPython.utils.jsonutil import json_clean
 from IPython.utils.traitlets import Any, Enum, Instance, List, Type
-from ipython_kernel.zmq.ipkernel import IPythonKernel
-from ipython_kernel.zmq.zmqshell import ZMQInteractiveShell
+from ipython_kernel.ipkernel import IPythonKernel
+from ipython_kernel.zmqshell import ZMQInteractiveShell
 
 from .socket import DummySocket
 
@@ -121,18 +121,18 b' class InProcessKernel(IPythonKernel):'
         return logging.getLogger(__name__)
 
     def _session_default(self):
-        from ipython_kernel.zmq.session import Session
+        from ipython_kernel.session import Session
         return Session(parent=self, key=b'')
 
     def _shell_class_default(self):
         return InProcessInteractiveShell
 
     def _stdout_default(self):
-        from ipython_kernel.zmq.iostream import OutStream
+        from ipython_kernel.iostream import OutStream
         return OutStream(self.session, self.iopub_socket, u'stdout', pipe=False)
 
     def _stderr_default(self):
-        from ipython_kernel.zmq.iostream import OutStream
+        from ipython_kernel.iostream import OutStream
         return OutStream(self.session, self.iopub_socket, u'stderr', pipe=False)
 
 #-----------------------------------------------------------------------------
@@ -150,7 +150,7 b' class InProcessInteractiveShell(ZMQInteractiveShell):'
 
     def enable_gui(self, gui=None):
         """Enable GUI integration for the kernel."""
-        from ipython_kernel.zmq.eventloops import enable_gui
+        from ipython_kernel.eventloops import enable_gui
         if not gui:
             gui = self.kernel.gui
         return enable_gui(gui, kernel=self.kernel)

ipython_kernel/ipkernel.py

@@ -10,7 +10,7 b' from IPython.utils.tokenutil import token_at_cursor, line_at_cursor'
 from IPython.utils.traitlets import Instance, Type, Any, List
 from IPython.utils.decorators import undoc
 
-from ..comm import CommManager
+from .comm import CommManager
 from .kernelbase import Kernel as KernelBase
 from .serialize import serialize_object, unpack_apply_message
 from .zmqshell import ZMQInteractiveShell
@@ -363,6 +363,6 b' class IPythonKernel(KernelBase):'
 class Kernel(IPythonKernel):
     def __init__(self, *args, **kwargs):
         import warnings
-        warnings.warn('Kernel is a deprecated alias of ipython_kernel.zmq.ipkernel.IPythonKernel',
+        warnings.warn('Kernel is a deprecated alias of ipython_kernel.ipkernel.IPythonKernel',
                       DeprecationWarning)
         super(Kernel, self).__init__(*args, **kwargs)

ipython_kernel/kernelapp.py

@@ -99,8 +99,8 b' class IPKernelApp(BaseIPythonApplication, InteractiveShellApp,'
     flags = Dict(kernel_flags)
     classes = [IPythonKernel, ZMQInteractiveShell, ProfileDir, Session]
     # the kernel class, as an importstring
-    kernel_class = Type('ipython_kernel.zmq.ipkernel.IPythonKernel', config=True,
-                        klass='ipython_kernel.zmq.kernelbase.Kernel',
+    kernel_class = Type('ipython_kernel.ipkernel.IPythonKernel', config=True,
+                        klass='ipython_kernel.kernelbase.Kernel',
     help="""The Kernel subclass to be used.
 
     This should allow easy re-use of the IPKernelApp entry point
@@ -124,9 +124,9 b' class IPKernelApp(BaseIPythonApplication, InteractiveShellApp,'
     # streams, etc.
     no_stdout = Bool(False, config=True, help="redirect stdout to the null device")
     no_stderr = Bool(False, config=True, help="redirect stderr to the null device")
-    outstream_class = DottedObjectName('ipython_kernel.zmq.iostream.OutStream',
+    outstream_class = DottedObjectName('ipython_kernel.iostream.OutStream',
         config=True, help="The importstring for the OutStream factory")
-    displayhook_class = DottedObjectName('ipython_kernel.zmq.displayhook.ZMQDisplayHook',
+    displayhook_class = DottedObjectName('ipython_kernel.displayhook.ZMQDisplayHook',
         config=True, help="The importstring for the DisplayHook factory")
 
     # polling

ipython_kernel/tests/test_serialize.py

@@ -9,7 +9,7 b' from collections import namedtuple'
 import nose.tools as nt
 
 # from unittest import TestCaes
-from ipython_kernel.zmq.serialize import serialize_object, deserialize_object
+from ipython_kernel.serialize import serialize_object, deserialize_object
 from IPython.testing import decorators as dec
 from IPython.utils.pickleutil import CannedArray, CannedClass
 from IPython.utils.py3compat import iteritems

ipython_kernel/zmqshell.py

@@ -46,9 +46,9 b' from IPython.utils import py3compat'
 from IPython.utils.py3compat import unicode_type
 from IPython.utils.traitlets import Instance, Type, Dict, CBool, CBytes, Any
 from IPython.utils.warn import error
-from ipython_kernel.zmq.displayhook import ZMQShellDisplayHook
-from ipython_kernel.zmq.datapub import ZMQDataPublisher
-from ipython_kernel.zmq.session import extract_header
+from ipython_kernel.displayhook import ZMQShellDisplayHook
+from ipython_kernel.datapub import ZMQDataPublisher
+from ipython_kernel.session import extract_header
 from .session import Session
 
 #-----------------------------------------------------------------------------