Add client 8 support (#996)

ipython · Sep 25, 2022 · 92292ad · 92292ad
1 parent b80e59e
commit 92292ad
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/ipykernel/inprocess/client.py b/ipykernel/inprocess/client.py
@@ -16,6 +16,11 @@
 from jupyter_client.client import KernelClient
 from jupyter_client.clientabc import KernelClientABC
 
+try:
+    from jupyter_client.utils import run_sync  # requires 7.0+
+except ImportError:
+    run_sync = None  # type:ignore
+
 # IPython imports
 from traitlets import Instance, Type, default
 
@@ -179,8 +184,12 @@ def _dispatch_to_kernel(self, msg):
         stream = kernel.shell_stream
         self.session.send(stream, msg)
         msg_parts = stream.recv_multipart()
-        loop = asyncio.get_event_loop()
-        loop.run_until_complete(kernel.dispatch_shell(msg_parts))
+        if run_sync:
+            dispatch_shell = run_sync(kernel.dispatch_shell)
+            dispatch_shell(msg_parts)
+        else:
+            loop = asyncio.get_event_loop()
+            loop.run_until_complete(kernel.dispatch_shell(msg_parts))
         idents, reply_msg = self.session.recv(stream, copy=False)
         self.shell_channel.call_handlers_later(reply_msg)