test: fix compatibility

Author: Lancetnik

.github/workflows/test.yml

@@ -40,7 +40,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version: ["3.8", "3.9", "3.10", "3.11"]
         pydantic-version: ["pydantic-v1", "pydantic-v2"]
       fail-fast: false
 

README.md

@@ -10,7 +10,6 @@
     <a href="https://pepy.tech/project/taskiq-faststream" target="_blank">
         <img src="https://static.pepy.tech/personalized-badge/taskiq-faststream?period=month&units=international_system&left_color=grey&right_color=blue" alt="downloads"/>
     </a>
-    <br/>
     <a href="https://pypi.org/project/taskiq-faststream" target="_blank">
         <img src="https://img.shields.io/pypi/pyversions/taskiq-faststream.svg" alt="Supported Python versions">
     </a>
@@ -79,12 +78,18 @@ taskiq_broker.task(
 )
 
 # create scheduler object
-scheduler=TaskiqScheduler(
+scheduler = TaskiqScheduler(
     broker=taskiq_broker,
     sources=[LabelScheduleSource(taskiq_broker)],
 )
 ```
 
+To run the scheduler, just use the following command
+
+```bash
+taskiq scheduler module:scheduler
+```
+
 Also, you can wrap your **FastStream** application the same way (allows to use lifespan events and AsyncAPI documentation):
 
 ```python
@@ -106,7 +111,7 @@ taskiq_broker = AppWrapper(app)
 # Code below omitted 👇
 ```
 
-Also, instead of using a final `message` argument, you can set a message callback to collect information right before sending:
+A little feature: instead of using a final `message` argument, you can set a message callback to collect information right before sending:
 
 ```python
 async def collect_information_to_send():

pyproject.toml

@@ -25,7 +25,6 @@ classifiers = [
     "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
-    "Programming Language :: Python :: 3.12",
     "Operating System :: OS Independent",
     "Topic :: Software Development :: Libraries :: Python Modules",
     "Topic :: Software Development :: Libraries",
@@ -61,14 +60,15 @@ kafka = [
 
 # local dev
 test = [
+    "taskiq-faststream[nats]",
+    "taskiq-faststream[rabbit]",
+    "taskiq-faststream[kafka]",
+
     "coverage[toml]>=7.2.0,<8.0.0",
     "pytest==7.4.3",
 ]
 
 dev = [
-    "taskiq-faststream[nats]",
-    "taskiq-faststream[rabbit]",
-    "taskiq-faststream[kafka]",
     "taskiq-faststream[test]",
 
     "mypy==1.7.0",

taskiq_faststream/broker.py

@@ -75,7 +75,7 @@ def task(  # type: ignore[override]
         *,
         schedule: typing.List[ScheduledTask],
         **kwargs: PublishParameters,
-    ) -> AsyncTaskiqDecoratedTask[[], None]:
+    ) -> "AsyncTaskiqDecoratedTask[[], None]":
         """Register FastStream scheduled task.
 
         Args:

tests/conftest.py

@@ -1,8 +1,8 @@
+import asyncio
 from unittest.mock import MagicMock
 from uuid import uuid4
 
 import pytest
-from anyio._backends._asyncio import Event
 
 
 @pytest.fixture(scope="session")
@@ -27,5 +27,6 @@ def mock() -> MagicMock:
 
 
 @pytest.fixture()
-def event() -> Event:
-    return Event()
+@pytest.mark.anyio
+async def event() -> asyncio.Event:
+    return asyncio.Event()

tests/testcase.py

@@ -4,7 +4,6 @@
 from unittest.mock import MagicMock
 
 import pytest
-from anyio import Event
 from faststream.broker.core.asyncronous import BrokerAsyncUsecase
 from faststream.utils.functions import timeout_scope
 from taskiq import AsyncBroker, TaskiqScheduler
@@ -30,7 +29,7 @@ async def test_task(
         subject: str,
         broker: BrokerAsyncUsecase[Any, Any],
         mock: MagicMock,
-        event: Event,
+        event: asyncio.Event,
     ) -> None:
         """Base testcase."""