diff --git a/pyinfra/queue/async_manager.py b/pyinfra/queue/async_manager.py
index 715869e..abdd38f 100644
--- 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(