release 0.4.1 (#133)

Author: Lancetnik

.github/workflows/test.yml

@@ -64,7 +64,7 @@ jobs:
           COVERAGE_FILE: coverage/.coverage.${{ runner.os }}-py${{ matrix.python-version }}-${{ matrix.pydantic-version }}
           CONTEXT: ${{ runner.os }}-py${{ matrix.python-version }}-${{ matrix.pydantic-version }}
       - name: Store coverage files
-        uses: actions/upload-artifact@v6
+        uses: actions/upload-artifact@v7
         with:
           name: .coverage.${{ runner.os }}-py${{ matrix.python-version }}-${{ matrix.pydantic-version }}
           path: coverage
@@ -87,7 +87,7 @@ jobs:
           version: "latest"
 
       - name: Get coverage files
-        uses: actions/download-artifact@v7
+        uses: actions/download-artifact@v8
         with:
           pattern: .coverage*
           path: coverage
@@ -101,7 +101,7 @@ jobs:
       - run: coverage html --show-contexts --title "taskiq-faststream coverage for ${{ github.sha }}"
 
       - name: Store coverage html
-        uses: actions/upload-artifact@v6
+        uses: actions/upload-artifact@v7
         with:
           name: coverage-html
           path: htmlcov

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "taskiq-faststream"
-version = "0.4.0"
+version = "0.4.1"
 description = "FastStream - taskiq integration to schedule FastStream tasks"
 readme = "README.md"
 license = "MIT"
@@ -41,7 +41,7 @@ classifiers = [
 
 dependencies = [
     "taskiq>=0.12.1,<0.13.0",
-    "faststream>=0.3.14,<0.7",
+    "faststream>=0.3.14,<0.8",
 ]
 
 [project.optional-dependencies]
@@ -84,8 +84,8 @@ test = [
 
 dev = [
     {include-group = "test"},
-    "mypy==1.19.1",
-    "ruff==0.14.10",
+    "mypy==1.20.0",
+    "ruff==0.15.9",
     "pre-commit >=3.6.0,<5.0.0",
 ]
 

taskiq_faststream/broker.py

@@ -56,7 +56,9 @@ async def startup(self) -> None:
 
     async def shutdown(self) -> None:
         """Shutdown wrapped FastStream broker."""
-        await self.broker.close()
+        # `stop` replaced `close` in FastStream 0.5.44; `close` removed in 0.7.0.
+        stop = getattr(self.broker, "stop", None) or self.broker.close
+        await stop()
         await super().shutdown()
 
     async def kick(self, message: PatchedMessage) -> None:  # type: ignore[override]