fix: add await to is_ready

2024-07-17 11:41:31 +02:00 · 2024-07-17 11:41:31 +02:00 · eeb4c3ce29
commit eeb4c3ce29
parent b8833c7560
1 changed files with 1 additions and 1 deletions
--- a/pyinfra/queue/async_manager.py
+++ b/pyinfra/queue/async_manager.py
@ -68,7 +68,7 @@ class AsyncQueueManager:

    async def is_ready(self) -> bool:
        await self.connect()
-        return self.channel.is_open
+        return await self.channel.is_open

    async def setup_exchanges(self) -> None:
        self.tenant_exchange = await self.channel.declare_exchange(