lint: fix rabbit mypy

airtai · Sep 8, 2024 · fbafc62 · fbafc62
1 parent d52e1fb
commit fbafc62
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/faststream/rabbit/subscriber/usecase.py b/faststream/rabbit/subscriber/usecase.py
@@ -183,6 +183,7 @@ async def close(self) -> None:
 
             self._queue_obj = None
 
+    @override
     async def get_one(
         self,
         *,
@@ -223,6 +224,8 @@ async def get_one(
             parsed_msg._decoded_body = await self._decoder(parsed_msg)
             return await return_msg(parsed_msg)
 
+        raise AssertionError("unreachable")
+
     def _make_response_publisher(
         self,
         message: "StreamMessage[Any]",