CHANGELOG.md

@@ -2,6 +2,27 @@
 
 <!-- <START NEW CHANGELOG ENTRY> -->
 
+## 8.5.0
+
+([Full Changelog](https://github.com/jupyter/jupyter_client/compare/v8.4.0...ff94e310c2af3546f2f9384e6b35fd11c3d09a71))
+
+### Enhancements made
+
+- Allow to update kernels env in between restart. [#987](https://github.com/jupyter/jupyter_client/pull/987) ([@Carreau](https://github.com/Carreau))
+
+### Maintenance and upkeep improvements
+
+- Enable strict typing [#984](https://github.com/jupyter/jupyter_client/pull/984) ([@blink1073](https://github.com/blink1073))
+- Update typings for mypy 1.6 [#983](https://github.com/jupyter/jupyter_client/pull/983) ([@blink1073](https://github.com/blink1073))
+
+### Contributors to this release
+
+([GitHub contributors page for this release](https://github.com/jupyter/jupyter_client/graphs/contributors?from=2023-10-11&to=2023-10-25&type=c))
+
+[@blink1073](https://github.com/search?q=repo%3Ajupyter%2Fjupyter_client+involves%3Ablink1073+updated%3A2023-10-11..2023-10-25&type=Issues) | [@Carreau](https://github.com/search?q=repo%3Ajupyter%2Fjupyter_client+involves%3ACarreau+updated%3A2023-10-11..2023-10-25&type=Issues)
+
+<!-- <END NEW CHANGELOG ENTRY> -->
+
 ## 8.4.0
 
 ([Full Changelog](https://github.com/jupyter/jupyter_client/compare/v8.3.1...74044393230e70134f68e664f2ef19fab92b7774))
@@ -22,8 +43,6 @@
 
 [@blink1073](https://github.com/search?q=repo%3Ajupyter%2Fjupyter_client+involves%3Ablink1073+updated%3A2023-08-29..2023-10-11&type=Issues) | [@dependabot](https://github.com/search?q=repo%3Ajupyter%2Fjupyter_client+involves%3Adependabot+updated%3A2023-08-29..2023-10-11&type=Issues) | [@ellert](https://github.com/search?q=repo%3Ajupyter%2Fjupyter_client+involves%3Aellert+updated%3A2023-08-29..2023-10-11&type=Issues) | [@pre-commit-ci](https://github.com/search?q=repo%3Ajupyter%2Fjupyter_client+involves%3Apre-commit-ci+updated%3A2023-08-29..2023-10-11&type=Issues)
 
-<!-- <END NEW CHANGELOG ENTRY> -->
-
 ## 8.3.1
 
 ([Full Changelog](https://github.com/jupyter/jupyter_client/compare/v8.3.0...b4f7d947fae55a4fe59a27df0830a9a78dcd4e12))

docs/conf.py

@@ -16,7 +16,7 @@
 import os.path as osp
 import shutil
 
-from sphinx.util import logging  # type:ignore[import]
+from sphinx.util import logging  # type:ignore[import-not-found]
 
 # If extensions (or modules to document with autodoc) are in another directory,
 # add these directories to sys.path here. If the directory is relative to the
@@ -51,7 +51,7 @@ def filter(self, record: pylogging.LogRecord) -> bool:
 # End of a workaround
 
 try:
-    import enchant  # type:ignore[import]  # noqa
+    import enchant  # type:ignore[import-not-found]  # noqa
 
     extensions += ["sphinxcontrib.spelling"]
 except ImportError:
@@ -329,7 +329,7 @@ def filter(self, record: pylogging.LogRecord) -> bool:
 intersphinx_mapping = {'ipython': ('http://ipython.readthedocs.io/en/stable/', None)}
 
 
-def setup(app):
+def setup(app: object) -> None:
     HERE = osp.abspath(osp.dirname(__file__))
     dest = osp.join(HERE, 'changelog.md')
     shutil.copy(osp.join(HERE, '..', 'CHANGELOG.md'), dest)

jupyter_client/_version.py

@@ -2,7 +2,7 @@
 import re
 from typing import List, Union
 
-__version__ = "8.4.0"
+__version__ = "8.5.0"
 
 # Build up version_info tuple for backwards compatibility
 pattern = r'(?P<major>\d+).(?P<minor>\d+).(?P<patch>\d+)(?P<rest>.*)'

jupyter_client/asynchronous/client.py

@@ -1,6 +1,9 @@
 """Implements an async kernel client"""
 # Copyright (c) Jupyter Development Team.
 # Distributed under the terms of the Modified BSD License.
+from __future__ import annotations
+
+import typing as t
 
 import zmq.asyncio
 from traitlets import Instance, Type
@@ -9,10 +12,10 @@
 from ..client import KernelClient, reqrep
 
 
-def wrapped(meth, channel):
+def wrapped(meth: t.Callable, channel: str) -> t.Callable:
     """Wrap a method on a channel and handle replies."""
 
-    def _(self, *args, **kwargs):
+    def _(self: AsyncKernelClient, *args: t.Any, **kwargs: t.Any) -> t.Any:
         reply = kwargs.pop("reply", False)
         timeout = kwargs.pop("timeout", None)
         msg_id = meth(self, *args, **kwargs)

jupyter_client/blocking/client.py

@@ -4,17 +4,21 @@
 """
 # Copyright (c) Jupyter Development Team.
 # Distributed under the terms of the Modified BSD License.
+from __future__ import annotations
+
+import typing as t
+
 from traitlets import Type
 
 from ..channels import HBChannel, ZMQSocketChannel
 from ..client import KernelClient, reqrep
 from ..utils import run_sync
 
 
-def wrapped(meth, channel):
+def wrapped(meth: t.Callable, channel: str) -> t.Callable:
     """Wrap a method on a channel and handle replies."""
 
-    def _(self, *args, **kwargs):
+    def _(self: BlockingKernelClient, *args: t.Any, **kwargs: t.Any) -> t.Any:
         reply = kwargs.pop("reply", False)
         timeout = kwargs.pop("timeout", None)
         msg_id = meth(self, *args, **kwargs)

jupyter_client/channels.py

@@ -54,7 +54,7 @@ def __init__(
         context: t.Optional[zmq.Context] = None,
         session: t.Optional[Session] = None,
         address: t.Union[t.Tuple[str, int], str] = "",
-    ):
+    ) -> None:
         """Create the heartbeat monitor thread.
 
         Parameters

jupyter_client/channelsabc.py

@@ -8,17 +8,17 @@ class ChannelABC(metaclass=abc.ABCMeta):
     """A base class for all channel ABCs."""
 
     @abc.abstractmethod
-    def start(self):
+    def start(self) -> None:
         """Start the channel."""
         pass
 
     @abc.abstractmethod
-    def stop(self):
+    def stop(self) -> None:
         """Stop the channel."""
         pass
 
     @abc.abstractmethod
-    def is_alive(self):
+    def is_alive(self) -> bool:
         """Test whether the channel is alive."""
         pass
 
@@ -32,20 +32,20 @@ class HBChannelABC(ChannelABC):
     """
 
     @abc.abstractproperty
-    def time_to_dead(self):
+    def time_to_dead(self) -> float:
         pass
 
     @abc.abstractmethod
-    def pause(self):
+    def pause(self) -> None:
         """Pause the heartbeat channel."""
         pass
 
     @abc.abstractmethod
-    def unpause(self):
+    def unpause(self) -> None:
         """Unpause the heartbeat channel."""
         pass
 
     @abc.abstractmethod
-    def is_beating(self):
+    def is_beating(self) -> bool:
         """Test whether the channel is beating."""
         pass

jupyter_client/client.py

@@ -113,7 +113,7 @@ def _context_default(self) -> zmq.Context:
     # flag for whether execute requests should be allowed to call raw_input:
     allow_stdin: bool = True
 
-    def __del__(self):
+    def __del__(self) -> None:
         """Handle garbage collection.  Destroy context if applicable."""
         if (
             self._created_context
@@ -511,7 +511,7 @@ async def _async_execute_interactive(
         if output_hook is None and "IPython" in sys.modules:
             from IPython import get_ipython
 
-            ip = get_ipython()
+            ip = get_ipython()  # type:ignore[no-untyped-call]
             in_kernel = getattr(ip, "kernel", False)
             if in_kernel:
                 output_hook = partial(

jupyter_client/clientabc.py

@@ -8,7 +8,13 @@
 # -----------------------------------------------------------------------------
 # Imports
 # -----------------------------------------------------------------------------
+from __future__ import annotations
+
 import abc
+from typing import TYPE_CHECKING, Any
+
+if TYPE_CHECKING:
+    from .channelsabc import ChannelABC
 
 # -----------------------------------------------------------------------------
 # Main kernel client class
@@ -24,64 +30,71 @@ class KernelClientABC(metaclass=abc.ABCMeta):
     """
 
     @abc.abstractproperty
-    def kernel(self):
+    def kernel(self) -> Any:
         pass
 
     @abc.abstractproperty
-    def shell_channel_class(self):
+    def shell_channel_class(self) -> type[ChannelABC]:
         pass
 
     @abc.abstractproperty
-    def iopub_channel_class(self):
+    def iopub_channel_class(self) -> type[ChannelABC]:
         pass
 
     @abc.abstractproperty
-    def hb_channel_class(self):
+    def hb_channel_class(self) -> type[ChannelABC]:
         pass
 
     @abc.abstractproperty
-    def stdin_channel_class(self):
+    def stdin_channel_class(self) -> type[ChannelABC]:
         pass
 
     @abc.abstractproperty
-    def control_channel_class(self):
+    def control_channel_class(self) -> type[ChannelABC]:
         pass
 
     # --------------------------------------------------------------------------
     # Channel management methods
     # --------------------------------------------------------------------------
 
     @abc.abstractmethod
-    def start_channels(self, shell=True, iopub=True, stdin=True, hb=True, control=True):
+    def start_channels(
+        self,
+        shell: bool = True,
+        iopub: bool = True,
+        stdin: bool = True,
+        hb: bool = True,
+        control: bool = True,
+    ) -> None:
         """Start the channels for the client."""
         pass
 
     @abc.abstractmethod
-    def stop_channels(self):
+    def stop_channels(self) -> None:
         """Stop the channels for the client."""
         pass
 
     @abc.abstractproperty
-    def channels_running(self):
+    def channels_running(self) -> bool:
         """Get whether the channels are running."""
         pass
 
     @abc.abstractproperty
-    def shell_channel(self):
+    def shell_channel(self) -> ChannelABC:
         pass
 
     @abc.abstractproperty
-    def iopub_channel(self):
+    def iopub_channel(self) -> ChannelABC:
         pass
 
     @abc.abstractproperty
-    def stdin_channel(self):
+    def stdin_channel(self) -> ChannelABC:
         pass
 
     @abc.abstractproperty
-    def hb_channel(self):
+    def hb_channel(self) -> ChannelABC:
         pass
 
     @abc.abstractproperty
-    def control_channel(self):
+    def control_channel(self) -> ChannelABC:
         pass