diff --git a/.github/workflows/publish_coverage.yml b/.github/workflows/publish_coverage.yml index f514c32e87..5553364b2c 100644 --- a/.github/workflows/publish_coverage.yml +++ b/.github/workflows/publish_coverage.yml @@ -22,7 +22,7 @@ jobs: - run: pip install smokeshow - - uses: dawidd6/action-download-artifact@v3.1.1 # nosemgrep + - uses: dawidd6/action-download-artifact@v3.1.2 # nosemgrep with: workflow: test.yaml commit: ${{ github.event.workflow_run.head_sha }} diff --git a/.secrets.baseline b/.secrets.baseline index 33835f7a2e..b7d89b9562 100644 --- a/.secrets.baseline +++ b/.secrets.baseline @@ -128,7 +128,7 @@ "filename": "docs/docs/en/release.md", "hashed_secret": "35675e68f4b5af7b995d9205ad0fc43842f16450", "is_verified": false, - "line_number": 625, + "line_number": 676, "is_secret": false } ], @@ -163,5 +163,5 @@ } ] }, - "generated_at": "2024-02-13T14:33:50Z" + "generated_at": "2024-02-27T08:00:31Z" } diff --git a/faststream/kafka/fastapi.py b/faststream/kafka/fastapi.py index bc4bbb19af..7e5de4f466 100644 --- a/faststream/kafka/fastapi.py +++ b/faststream/kafka/fastapi.py @@ -49,8 +49,7 @@ def subscriber( [Callable[P_HandlerParams, T_HandlerReturn]], HandlerCallWrapper[ConsumerRecord, P_HandlerParams, T_HandlerReturn], ]: - return super().subscriber( - topics[0], *topics, **broker_kwargs) + return super().subscriber(topics[0], *topics, **broker_kwargs) @staticmethod def _setup_log_context( diff --git a/pyproject.toml b/pyproject.toml index 753e1d212b..488f66a7bc 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -82,12 +82,12 @@ docs = [ # dev dependencies devdocs = [ - "mkdocs-material==9.5.10", + "mkdocs-material==9.5.11", "mkdocs-static-i18n==1.2.0", "mdx-include==1.4.2", "mkdocstrings[python]==0.24.0", "mkdocs-literate-nav==0.6.1", - "mkdocs-git-revision-date-localized-plugin==1.2.2", + "mkdocs-git-revision-date-localized-plugin==1.2.4", "mike==2.0.0", # versioning "mkdocs-minify-plugin==0.7.2", "mkdocs-macros-plugin==1.0.5", # includes with variables @@ -108,8 +108,8 @@ lint = [ "confluent-kafka-stubs; python_version >= '3.11'", "mypy==1.8.0", "ruff==0.2.1", - "bandit==1.7.6", - "semgrep==1.61.1", + "bandit==1.7.7", + "semgrep==1.62.0", ] test-core = [ @@ -125,7 +125,7 @@ testing = [ "faststream[test-core]", "fastapi==0.109.2", "pydantic-settings>=2.0.0,<3.0.0", - "httpx==0.26.0", + "httpx==0.27.0", "PyYAML==6.0.1", "watchfiles==0.21.0", "email-validator==2.1.0.post1", diff --git a/tests/brokers/redis/test_consume.py b/tests/brokers/redis/test_consume.py index 16fbf559ae..6227790571 100644 --- a/tests/brokers/redis/test_consume.py +++ b/tests/brokers/redis/test_consume.py @@ -243,7 +243,9 @@ async def test_consume_group_with_last_id( queue: str, full_broker: RedisBroker, ): - @full_broker.subscriber(stream=StreamSub(queue, group="group", consumer=queue, last_id="0")) + @full_broker.subscriber( + stream=StreamSub(queue, group="group", consumer=queue, last_id="0") + ) async def handler(msg: RedisMessage): ...