Fix: rename message vars, avoid overwrite

airtai · Sep 20, 2024 · 006ca45 · 006ca45
1 parent c283183
commit 006ca45
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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: