Drop support for Python 3.9 (#238)

Author: jodal

.github/workflows/ci.yml

@@ -19,9 +19,6 @@ jobs:
       fail-fast: false
       matrix:
         include:
-          - name: "pytest (3.9)"
-            python: "3.9"
-            tox: "3.9"
           - name: "pytest (3.10)"
             python: "3.10"
             tox: "3.10"

README.md

@@ -20,7 +20,7 @@ see the [documentation](https://pykka.readthedocs.io/).
 
 ## Installation
 
-Pykka requires Python 3.9 or newer.
+Pykka requires Python 3.10 or newer.
 
 Pykka is available from [PyPI](https://pypi.org/project/pykka/):
 

docs/index.rst

@@ -14,7 +14,7 @@ Pykka is available from PyPI. To install it, run::
 
     pip install pykka
 
-Pykka works with Python 3.9 or newer.
+Pykka works with Python 3.10 or newer.
 
 
 Inspiration

examples/resolver.py

@@ -41,7 +41,7 @@ def run(pool_size, *ips):
         hosts.append(resolvers[i % len(resolvers)].resolve(ip))
 
     # Gather results (blocking)
-    ip_to_host = zip(ips, pykka.get_all(hosts))
+    ip_to_host = zip(ips, pykka.get_all(hosts), strict=True)
     pprint.pprint(list(ip_to_host))
 
     # Clean up

pyproject.toml

@@ -3,7 +3,7 @@ name = "pykka"
 version = "4.2.0"
 description = "Pykka is a Python implementation of the actor model"
 authors = [{ name = "Stein Magnus Jodal", email = "stein.magnus@jodal.no" }]
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "Apache-2.0"
 keywords = ["actor", "concurrency", "threading"]
@@ -12,7 +12,6 @@ classifiers = [
     "Intended Audience :: Developers",
     "Topic :: Software Development :: Libraries",
 ]
-dependencies = ["typing-extensions>=4.0.0 ; python_version < '3.10'"]
 
 [project.urls]
 "Source code" = "https://github.com/jodal/pykka"
@@ -34,7 +33,11 @@ dev = [
     { include-group = "ruff" },
     { include-group = "tests" },
 ]
-docs = ["sphinx>=6.2.1", "sphinx_rtd_theme>=1.3.0", "tomli>=2.0.1 ; python_version < '3.11'"]
+docs = [
+    "sphinx>=6.2.1",
+    "sphinx_rtd_theme>=1.3.0",
+    "tomli>=2.0.1 ; python_version < '3.11'",
+]
 mypy = ["mypy>=1.17.1"]
 pyright = ["pyright>=1.1.403"]
 ruff = ["ruff>=0.12.8"]
@@ -63,7 +66,7 @@ warn_unused_configs = true
 
 
 [tool.pyright]
-pythonVersion = "3.9"
+pythonVersion = "3.10"
 typeCheckingMode = "strict"
 # Already coverd by tests and careful import ordering:
 reportImportCycles = false
@@ -72,7 +75,7 @@ reportPrivateUsage = false
 
 
 [tool.ruff]
-target-version = "py39"
+target-version = "py310"
 
 [tool.ruff.lint]
 select = ["ALL"]
@@ -120,7 +123,6 @@ keep-runtime-typing = true
 
 [tool.tox]
 env_list = [
-    "3.9",
     "3.10",
     "3.11",
     "3.12",

src/pykka/_actor.py

@@ -5,7 +5,7 @@
 import sys
 import threading
 import uuid
-from typing import TYPE_CHECKING, Any, Optional, Protocol, TypeVar
+from typing import TYPE_CHECKING, Any, Protocol, TypeVar
 
 from pykka import ActorDeadError, ActorRef, ActorRegistry, messages
 from pykka._introspection import get_attr_directly
@@ -310,9 +310,9 @@ def on_stop(self) -> None:  # noqa: B027
 
     def _handle_failure(
         self,
-        exception_type: Optional[type[BaseException]],
-        exception_value: Optional[BaseException],
-        traceback: Optional[TracebackType],
+        exception_type: type[BaseException] | None,
+        exception_value: BaseException | None,
+        traceback: TracebackType | None,
     ) -> None:
         """Log unexpected failures, unregisters and stops the actor."""
         logger.error(
@@ -324,9 +324,9 @@ def _handle_failure(
 
     def on_failure(  # noqa: B027
         self,
-        exception_type: Optional[type[BaseException]],
-        exception_value: Optional[BaseException],
-        traceback: Optional[TracebackType],
+        exception_type: type[BaseException] | None,
+        exception_value: BaseException | None,
+        traceback: TracebackType | None,
     ) -> None:
         """Run code when an unhandled exception is raised.
 

src/pykka/_envelope.py

@@ -1,6 +1,6 @@
 from __future__ import annotations
 
-from typing import TYPE_CHECKING, Any, Generic, Optional, TypeVar
+from typing import TYPE_CHECKING, Any, Generic, TypeVar
 
 if TYPE_CHECKING:
     from pykka import Future
@@ -24,9 +24,9 @@ class Envelope(Generic[T]):
     __slots__ = ["message", "reply_to"]
 
     message: T
-    reply_to: Optional[Future[Any]]
+    reply_to: Future[Any] | None
 
-    def __init__(self, message: T, reply_to: Optional[Future[Any]] = None) -> None:
+    def __init__(self, message: T, reply_to: Future[Any] | None = None) -> None:
         self.message = message
         self.reply_to = reply_to
 

src/pykka/_future.py

@@ -1,21 +1,17 @@
 from __future__ import annotations
 
 import functools
+from collections.abc import Callable, Generator, Iterable
 from typing import (
     TYPE_CHECKING,
     Any,
-    Callable,
     Generic,
-    Optional,
+    TypeAlias,
     TypeVar,
     cast,
 )
 
 if TYPE_CHECKING:
-    from collections.abc import Generator, Iterable
-
-    from typing_extensions import TypeAlias
-
     from pykka._types import OptExcInfo
 
 __all__ = ["Future", "get_all"]
@@ -26,7 +22,7 @@
 M = TypeVar("M")  # Result of Future.map()
 R = TypeVar("R")  # Result of Future.reduce()
 
-GetHookFunc: TypeAlias = Callable[[Optional[float]], T]
+GetHookFunc: TypeAlias = Callable[[float | None], T]
 
 
 class Future(Generic[T]):
@@ -38,8 +34,8 @@ class Future(Generic[T]):
     ``await`` the future.
     """
 
-    _get_hook: Optional[GetHookFunc[T]]
-    _get_hook_result: Optional[T]
+    _get_hook: GetHookFunc[T] | None
+    _get_hook_result: T | None
 
     def __init__(self) -> None:
         super().__init__()
@@ -52,7 +48,7 @@ def __repr__(self) -> str:
     def get(
         self,
         *,
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> T:
         """Get the value encapsulated by the future.
 
@@ -82,7 +78,7 @@ def get(
 
     def set(
         self,
-        value: Optional[T] = None,
+        value: T | None = None,
     ) -> None:
         """Set the encapsulated value.
 
@@ -94,7 +90,7 @@ def set(
 
     def set_exception(
         self,
-        exc_info: Optional[OptExcInfo] = None,
+        exc_info: OptExcInfo | None = None,
     ) -> None:
         """Set an exception as the encapsulated value.
 
@@ -293,7 +289,7 @@ def __await__(self) -> Generator[None, None, T]:
 def get_all(
     futures: Iterable[Future[T]],
     *,
-    timeout: Optional[float] = None,
+    timeout: float | None = None,
 ) -> Iterable[T]:
     """Collect all values encapsulated in the list of futures.
 

src/pykka/_proxy.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import logging
-from typing import TYPE_CHECKING, Any, Generic, Optional, TypeVar
+from typing import TYPE_CHECKING, Any, Generic, TypeVar
 
 from pykka import ActorDeadError, messages
 from pykka._introspection import AttrInfo, introspect_attrs
@@ -131,7 +131,7 @@ def __init__(
         self,
         *,
         actor_ref: ActorRef[A],
-        attr_path: Optional[AttrPath] = None,
+        attr_path: AttrPath | None = None,
     ) -> None:
         if not actor_ref.is_alive():
             msg = f"{actor_ref} not found"

src/pykka/_ref.py

@@ -5,7 +5,6 @@
     Any,
     Generic,
     Literal,
-    Optional,
     TypeVar,
     Union,
     overload,
@@ -104,7 +103,7 @@ def ask(
         message: Any,
         *,
         block: Literal[False],
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Future[Any]: ...
 
     @overload
@@ -113,7 +112,7 @@ def ask(
         message: Any,
         *,
         block: Literal[True],
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Any: ...
 
     @overload
@@ -122,15 +121,15 @@ def ask(
         message: Any,
         *,
         block: bool = True,
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Union[Any, Future[Any]]: ...
 
     def ask(
         self,
         message: Any,
         *,
         block: bool = True,
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Union[Any, Future[Any]]:
         """Send message to actor and wait for the reply.
 
@@ -178,30 +177,30 @@ def stop(
         self,
         *,
         block: Literal[True],
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> bool: ...
 
     @overload
     def stop(
         self,
         *,
         block: Literal[False],
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Future[bool]: ...
 
     @overload
     def stop(
         self,
         *,
         block: bool = True,
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Union[Any, Future[Any]]: ...
 
     def stop(
         self,
         *,
         block: bool = True,
-        timeout: Optional[float] = None,
+        timeout: float | None = None,
     ) -> Union[Any, Future[Any]]:
         """Send a message to the actor, asking it to stop.
 
@@ -223,7 +222,7 @@ def stop(
         """
         ask_future = self.ask(_ActorStop(), block=False)
 
-        def _stop_result_converter(timeout: Optional[float]) -> bool:
+        def _stop_result_converter(timeout: float | None) -> bool:
             try:
                 ask_future.get(timeout=timeout)
             except ActorDeadError: