From 006ca45bf24756a447c492e4759a5e6bd442d2c8 Mon Sep 17 00:00:00 2001 From: Daniil Dumchenko Date: Fri, 20 Sep 2024 23:30:50 +0700 Subject: [PATCH] Fix: rename message vars, avoid overwrite --- faststream/_internal/broker/broker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/faststream/_internal/broker/broker.py b/faststream/_internal/broker/broker.py index 0932ea2327..ee6bd0637e 100644 --- a/faststream/_internal/broker/broker.py +++ b/faststream/_internal/broker/broker.py @@ -368,13 +368,13 @@ async def request( **kwargs, ) - msg: Any = await process_msg( + message: Any = await process_msg( msg=published_msg, middlewares=self._middlewares, parser=producer._parser, decoder=producer._decoder, ) - return msg + return message @abstractmethod async def ping(self, timeout: Optional[float]) -> bool: