diff --git a/faststream/broker/wrapper/call.py b/faststream/broker/wrapper/call.py index f991e1b749..2dda3bf1ea 100644 --- a/faststream/broker/wrapper/call.py +++ b/faststream/broker/wrapper/call.py @@ -1,5 +1,4 @@ import asyncio -from functools import wraps from typing import ( TYPE_CHECKING, Any, @@ -186,13 +185,9 @@ def set_wrapped( def _wrap_decode_message( func: Callable[..., Awaitable[T_HandlerReturn]], params_ln: int, -) -> Callable[ - ["StreamMessage[MsgType]"], - Awaitable[T_HandlerReturn], -]: +) -> Callable[["StreamMessage[MsgType]"], Awaitable[T_HandlerReturn]]: """Wraps a function to decode a message and pass it as an argument to the wrapped function.""" - @wraps(func) async def decode_wrapper(message: "StreamMessage[MsgType]") -> T_HandlerReturn: """A wrapper function to decode and handle a message.""" msg = message.decoded_body diff --git a/pyproject.toml b/pyproject.toml index b8af94fd6a..3f22e04023 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -78,7 +78,7 @@ devdocs = [ "mkdocs-material==9.5.18", "mkdocs-static-i18n==1.2.2", "mdx-include==1.4.2", - "mkdocstrings[python]==0.24.3", + "mkdocstrings[python]==0.25.0", "mkdocs-literate-nav==0.6.1", "mkdocs-git-revision-date-localized-plugin==1.2.4", "mike==2.0.0", # versioning @@ -93,7 +93,7 @@ devdocs = [ types = [ "faststream[rabbit,confluent,kafka,nats,redis]", - "mypy==1.9.0", + "mypy==1.10.0", # mypy extensions "types-PyYAML", "types-setuptools", @@ -106,15 +106,15 @@ types = [ lint = [ "faststream[types]", - "ruff==0.4.1", + "ruff==0.4.2", "bandit==1.7.8", - "semgrep==1.69.0", + "semgrep==1.70.0", "codespell==2.2.6", ] test-core = [ "coverage[toml]==7.4.4", - "pytest==8.1.1", + "pytest==8.2.0", "pytest-asyncio==0.23.6", "dirty-equals==0.7.1.post0", ]