fix passing coroutine to asyncio.wait

Yakifo · Apr 17, 2022 · f95f97b · f95f97b
1 parent c88bd08
commit f95f97b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/amqtt/mqtt/protocol/handler.py b/amqtt/mqtt/protocol/handler.py
@@ -176,7 +176,11 @@ async def _retry_deliveries(self):
         for message in itertools.chain(
             self.session.inflight_in.values(), self.session.inflight_out.values()
         ):
-            tasks.append(asyncio.wait_for(self._handle_message_flow(message), 10))
+            tasks.append(
+                asyncio.create_task(
+                    asyncio.wait_for(self._handle_message_flow(message), 10)
+                )
+            )
         if tasks:
             done, pending = await asyncio.wait(tasks)
             self.logger.debug("%d messages redelivered" % len(done))