diff --git a/.gitignore b/.gitignore index e8630aa02..73fd7fdce 100644 --- a/.gitignore +++ b/.gitignore @@ -14,6 +14,7 @@ __pycache__ .coverage .cache absolute.json +*.swp # Sphinx documentation _build diff --git a/jupyter_client/ioloop/manager.py b/jupyter_client/ioloop/manager.py index f6dee3641..150ead883 100644 --- a/jupyter_client/ioloop/manager.py +++ b/jupyter_client/ioloop/manager.py @@ -57,6 +57,7 @@ def stop_restarter(self): self._restarter = None connect_shell = as_zmqstream(KernelManager.connect_shell) + connect_control = as_zmqstream(KernelManager.connect_control) connect_iopub = as_zmqstream(KernelManager.connect_iopub) connect_stdin = as_zmqstream(KernelManager.connect_stdin) connect_hb = as_zmqstream(KernelManager.connect_hb) diff --git a/jupyter_client/multikernelmanager.py b/jupyter_client/multikernelmanager.py index c2b61bde0..9489421d0 100644 --- a/jupyter_client/multikernelmanager.py +++ b/jupyter_client/multikernelmanager.py @@ -284,6 +284,22 @@ def connect_shell(self, kernel_id, identity=None): stream : zmq Socket or ZMQStream """ + @kernel_method + def connect_control(self, kernel_id, identity=None): + """Return a zmq Socket connected to the control channel. + + Parameters + ========== + kernel_id : uuid + The id of the kernel + identity : bytes (optional) + The zmq identity of the socket + + Returns + ======= + stream : zmq Socket or ZMQStream + """ + @kernel_method def connect_stdin(self, kernel_id, identity=None): """Return a zmq Socket connected to the stdin channel.