diff --git a/faststream/asgi/app.py b/faststream/asgi/app.py index 4cbaae0e64..33ffec16d7 100644 --- a/faststream/asgi/app.py +++ b/faststream/asgi/app.py @@ -172,7 +172,7 @@ async def run( config = uvicorn.Config( app=self, log_level=log_level, - **{ + **{ # type: ignore[arg-type] key: v for key, v in run_extra_options.items() if key in uvicorn_config_params diff --git a/faststream/message/message.py b/faststream/message/message.py index a7db6f895d..2037e7dc98 100644 --- a/faststream/message/message.py +++ b/faststream/message/message.py @@ -12,7 +12,7 @@ from .source_type import SourceType if TYPE_CHECKING: - from faststream._internal.basic_types import AnyDict, DecodedMessage + from faststream._internal.basic_types import AnyDict from faststream._internal.types import AsyncCallable # prevent circular imports @@ -74,7 +74,7 @@ def __repr__(self) -> str: filter( bool, ( - f"body={self.body}", + f"body={self.body!r}", f"content_type={self.content_type}", f"message_id={self.message_id}", f"correlation_id={self.correlation_id}", @@ -89,7 +89,7 @@ def __repr__(self) -> str: return f"{self.__class__.__name__}({inner})" - async def decode(self) -> Optional["DecodedMessage"]: + async def decode(self) -> Optional["Any"]: """Serialize the message by lazy decoder. Returns a cache after first usage. To prevent such behavior, please call