fix latest ci

Author: chirizxc

noxfile.py

@@ -57,6 +57,7 @@ def python_version_less(*version: int) -> Constraint:
     IntegrationEnv("faststream", "050", python_version_less(3, 13)),
     IntegrationEnv("faststream", "0529", python_version_less(3, 14)),
     IntegrationEnv("faststream", "060"),
+    IntegrationEnv("faststream", "070"),
     IntegrationEnv("faststream", "latest"),
     IntegrationEnv("flask", "302"),
     IntegrationEnv("flask", "latest"),

requirements/faststream-070.txt

@@ -0,0 +1,4 @@
+-r test.txt
+
+faststream[nats]==0.7.1
+fast-depends==3.0.8

requirements/test.txt

@@ -1,4 +1,4 @@
 pytest~=9.0.1
-pytest-asyncio==1.3.*
+pytest-asyncio==1.4.*
 pytest-repeat==0.9.*
 pytest-cov==7.*

src/dishka/integrations/faststream/__init__.py

@@ -15,12 +15,11 @@
     stacklevel=2,
 )
 
-FASTSTREAM_05 = FASTSTREAM_VERSION.startswith("0.5")
-FASTSTREAM_06 = FASTSTREAM_VERSION.startswith("0.6")
-
-if FASTSTREAM_05:
+if FASTSTREAM_VERSION.startswith("0.5"):
     from .faststream_05 import FastStreamProvider, inject, setup_dishka
-elif FASTSTREAM_06:
+elif (
+    FASTSTREAM_VERSION.startswith(("0.6", "0.7"))
+):
     from .faststream_06 import (  # type: ignore[assignment]
         FastStreamProvider,
         inject,

src/dishka/integrations/faststream/faststream_06.py

@@ -41,8 +41,10 @@ class FastStreamProvider(Provider):
 
 try:
     # import works only if fastapi is installed
-    from faststream._internal.fastapi import Context as FastAPIContext
-    from faststream._internal.fastapi import StreamRouter
+    from faststream._internal.fastapi import (
+        Context as FastAPIContext,
+        StreamRouter,
+    )
 
 except ImportError:
     ContextAnnotation: TypeAlias = Annotated[ContextRepo, Context("context")]

tests/integrations/faststream/test_faststream_05.py

@@ -27,7 +27,7 @@
 
 # `broker.request` was introduced in FastStream 0.5.19
 # `broker.publish(..., rpc=True)` was removed in FastStream 0.6.0rc0
-if FASTSTREAM_VERSION.startswith("0.6"):
+if FASTSTREAM_VERSION.startswith(("0.6", "0.7")):
     pytestmark = pytest.mark.skip(
         reason="These tests is not compatible with FastStream 0.6",
     )