feat: remove support for python 3.9

Author: danfimov

.github/workflows/test.yml

@@ -42,7 +42,7 @@ jobs:
   pytest:
     strategy:
       matrix:
-        py_version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
+        py_version: ["3.10", "3.11", "3.12", "3.13"]
         pydantic_ver: ["<2", ">=2.5,<3"]
         os: [ubuntu-latest, windows-latest, macos-latest]
     runs-on: "${{ matrix.os }}"

.python-version

@@ -2,4 +2,3 @@
 3.12.8
 3.11.11
 3.10.16
-3.9.21

poetry.lock

@@ -19,7 +19,6 @@ classifiers = [
     "Programming Language :: Python",
     "Programming Language :: Python :: 3",
     "Programming Language :: Python :: 3 :: Only",
-    "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
     "Programming Language :: Python :: 3.12",
@@ -30,7 +29,7 @@ classifiers = [
     "Development Status :: 3 - Alpha",
 ]
 keywords = ["taskiq", "tasks", "distributed", "async"]
-requires-python = ">=3.9,<4"
+requires-python = ">=3.10,<4"
 dependencies = [
     "typing-extensions>=3.10.0.0; python_version < '3.11'",
     "pydantic>=1.0,<=3.0",
@@ -99,6 +98,7 @@ worker = "taskiq.cli.worker.cmd:WorkerCMD"
 scheduler = "taskiq.cli.scheduler.cmd:SchedulerCMD"
 
 [tool.mypy]
+python_version = "3.10"
 strict = true
 ignore_missing_imports = true
 allow_subclassing_any = true
@@ -135,7 +135,7 @@ requires = ["poetry-core>=1.0.0"]
 build-backend = "poetry.core.masonry.api"
 
 [tool.ruff]
-target-version="py39"
+target-version="py310"
 # List of enabled rulsets.
 # See https://docs.astral.sh/ruff/rules/ for more information.
 lint.select = [

pyproject.toml

@@ -16,6 +16,8 @@
     Dict,
     List,
     Optional,
+    ParamSpec,
+    TypeAlias,
     TypeVar,
     Union,
     get_type_hints,
@@ -38,13 +40,9 @@
 from taskiq.warnings import TaskiqDeprecationWarning
 
 if sys.version_info >= (3, 11):
-    from typing import ParamSpec, Self, TypeAlias
-elif sys.version_info >= (3, 10):
-    from typing import ParamSpec, TypeAlias
-
-    from typing_extensions import Self
+    from typing import Self
 else:
-    from typing_extensions import ParamSpec, Self, TypeAlias
+    from typing_extensions import Self
 
 
 if TYPE_CHECKING:  # pragma: no cover

taskiq/abc/broker.py

@@ -1,18 +1,11 @@
-import sys
-from typing import Any, AsyncGenerator, Optional, TypeVar
+from typing import Any, AsyncGenerator, Optional, ParamSpec, TypeVar
 
 from taskiq.abc.broker import AsyncBroker
 from taskiq.decor import AsyncTaskiqDecoratedTask
 from taskiq.exceptions import SharedBrokerListenError, SharedBrokerSendTaskError
 from taskiq.kicker import AsyncKicker
 from taskiq.message import BrokerMessage
 
-if sys.version_info >= (3, 10):
-    from typing import ParamSpec
-else:
-    from typing_extensions import ParamSpec
-
-
 _ReturnType = TypeVar("_ReturnType")
 _Params = ParamSpec("_Params")
 

taskiq/brokers/shared_broker.py

@@ -71,7 +71,7 @@ async def get_all_schedules(
     schedules = await asyncio.gather(
         *[get_schedules(source) for source in scheduler.sources],
     )
-    return list(zip(scheduler.sources, schedules))
+    return list(zip(scheduler.sources, schedules, strict=False))
 
 
 def get_task_delay(task: ScheduledTask) -> Optional[int]:

taskiq/cli/scheduler/run.py

@@ -210,7 +210,7 @@ def prepare_workers(self) -> None:
             events.append(event)
 
         # Wait for workers startup
-        for worker, event in zip(self.workers, events):
+        for worker, event in zip(self.workers, events, strict=False):
             _wait_for_worker_startup(worker, event)
 
     def start(self) -> Optional[int]:  # noqa: C901

taskiq/cli/worker/process_manager.py

@@ -9,6 +9,7 @@
     Dict,
     Generic,
     Optional,
+    ParamSpec,
     Type,
     TypeVar,
     Union,
@@ -19,11 +20,6 @@
 from taskiq.scheduler.created_schedule import CreatedSchedule
 from taskiq.task import AsyncTaskiqTask
 
-if sys.version_info >= (3, 10):
-    from typing import ParamSpec
-else:
-    from typing_extensions import ParamSpec
-
 if TYPE_CHECKING:  # pragma: no cover
     from taskiq.abc.broker import AsyncBroker
     from taskiq.abc.schedule_source import ScheduleSource

taskiq/decor.py

@@ -1,4 +1,3 @@
-import sys
 from collections.abc import Coroutine
 from dataclasses import asdict, is_dataclass
 from datetime import datetime
@@ -10,6 +9,7 @@
     Dict,
     Generic,
     Optional,
+    ParamSpec,
     Type,
     TypeVar,
     Union,
@@ -28,11 +28,6 @@
 from taskiq.task import AsyncTaskiqTask
 from taskiq.utils import maybe_awaitable
 
-if sys.version_info >= (3, 10):
-    from typing import ParamSpec
-else:
-    from typing_extensions import ParamSpec
-
 if TYPE_CHECKING:  # pragma: no cover
     from taskiq.abc.broker import AsyncBroker
     from taskiq.abc.schedule_source import ScheduleSource