fix: FastStream 0.3.13 compat

Author: Lancetnik

pyproject.toml

@@ -43,7 +43,7 @@ dynamic = ["version"]
 
 dependencies = [
     "taskiq>=0.10.0,<1.0.0",
-    "faststream>=0.3.0,<1.0.0",
+    "faststream>=0.3.14,<0.5.0",
 ]
 
 [project.optional-dependencies]
@@ -78,7 +78,7 @@ dev = [
     "taskiq-faststream[test]",
 
     "mypy>=1.8.0,<1.9.0",
-    "ruff==0.1.11",
+    "ruff==0.1.13",
     "pre-commit >=3.6.0,<4.0.0",
 ]
 

taskiq_faststream/__about__.py

@@ -1,2 +1,2 @@
 """FastStream - taskiq integration to schedule FastStream tasks."""
-__version__ = "0.1.6"
+__version__ = "0.1.7"

taskiq_faststream/broker.py

@@ -2,13 +2,13 @@
 import warnings
 
 import anyio
-from faststream._compat import TypeAlias, override
 from faststream.app import FastStream
-from faststream.broker.core.asyncronous import BrokerAsyncUsecase
+from faststream.broker.core.asynchronous import BrokerAsyncUsecase
 from faststream.types import SendableMessage
 from taskiq import AsyncBroker, BrokerMessage
 from taskiq.acks import AckableMessage
 from taskiq.decor import AsyncTaskiqDecoratedTask
+from typing_extensions import TypeAlias, override
 
 from taskiq_faststream.serializer import PatchedSerializer
 from taskiq_faststream.types import ScheduledTask

taskiq_faststream/types.py

@@ -1,7 +1,7 @@
 from datetime import datetime, timedelta
 from typing import Optional, Union
 
-from faststream._compat import TypedDict
+from typing_extensions import TypedDict
 
 
 class ScheduledTask(TypedDict, total=False):

tests/testcase.py

@@ -4,7 +4,7 @@
 from unittest.mock import MagicMock
 
 import pytest
-from faststream.broker.core.asyncronous import BrokerAsyncUsecase
+from faststream.broker.core.asynchronous import BrokerAsyncUsecase
 from faststream.utils.functions import timeout_scope
 from taskiq import AsyncBroker, TaskiqScheduler
 from taskiq.cli.scheduler.args import SchedulerArgs