test: Fixed broker init.

Author: xelandernt

.github/workflows/ci.yml

@@ -34,8 +34,8 @@ jobs:
           - "3.13"
           - "3.14"
         faststream-version:
-          - "0.5.48"
-          - "0.6.2"
+          - "<0.6.0"
+          - ">=0.6.0"
     steps:
       - uses: actions/checkout@v5
       - uses: extractions/setup-just@v3
@@ -44,7 +44,7 @@ jobs:
           cache-dependency-glob: "**/pyproject.toml"
       - run: uv python install ${{ matrix.python-version }}
       - run: just install
-      - run: uv run --with faststream==${{ matrix.faststream-version }} pytest . --cov=. --cov-report xml
+      - run: uv run --with "faststream${{ matrix.faststream-version }}" pytest . --cov=. --cov-report xml
       - uses: codecov/codecov-action@v5.4.3
         env:
           CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}

tests/integrations/faststream/test_faststream_di_pass_message.py

@@ -9,9 +9,9 @@
 from that_depends.integrations.faststream import _FASTSTREAM_VERSION
 
 
-if Version(_FASTSTREAM_VERSION) >= Version("0.6.0"):
+if Version(_FASTSTREAM_VERSION) >= Version("0.6.0"):  # pragma: no cover
     from faststream.message import StreamMessage
-else:
+else:  # pragma: no cover
     from faststream.broker.message import StreamMessage  # type: ignore[import-not-found, no-redef]
 
 
@@ -25,7 +25,11 @@ async def consume_scope(
             return await call_next(msg)
 
 
-broker = NatsBroker(middlewares=(ContextMiddleware,))
+if Version(_FASTSTREAM_VERSION) >= Version("0.6.0"):  # pragma: no cover
+    broker = NatsBroker(middlewares=(ContextMiddleware,))
+
+else:  # pragma: no cover
+    broker = NatsBroker(middlewares=(ContextMiddleware,), validate=False)  # type: ignore[call-arg]
 
 TEST_SUBJECT = "test"
 

that_depends/integrations/faststream.py

@@ -13,7 +13,7 @@
 
 _FASTSTREAM_MODULE_NAME: Final[str] = "faststream"
 _FASTSTREAM_VERSION: Final[str] = version(_FASTSTREAM_MODULE_NAME)
-if Version(_FASTSTREAM_VERSION) >= Version("0.6.0"):
+if Version(_FASTSTREAM_VERSION) >= Version("0.6.0"):  # pragma: no cover
     from faststream import BaseMiddleware, ContextRepo
 
     class DIContextMiddleware(BaseMiddleware):
@@ -83,7 +83,7 @@ def __call__(self, msg: Any = None, **kwargs: Any) -> "DIContextMiddleware":  #
                 scope=self._scope,
                 global_context=self._global_context,
             )
-else:
+else:  # pragma: no cover
     from faststream import BaseMiddleware
 
     @deprecated("Will be removed with faststream v1")