From 2bc332831e3b24b3c3118524a01ba5d158bc7d03 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonathan=20K=C3=B6ssler?= Date: Fri, 16 Aug 2024 12:37:28 +0200 Subject: [PATCH] fix: use is_initialized instead of is_open --- pyinfra/queue/async_manager.py | 2 +- pyproject.toml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pyinfra/queue/async_manager.py b/pyinfra/queue/async_manager.py index 75efd8e..9031e24 100644 --- a/pyinfra/queue/async_manager.py +++ b/pyinfra/queue/async_manager.py @@ -80,7 +80,7 @@ class AsyncQueueManager: async def is_ready(self) -> bool: await self.connect() - return await self.channel.is_open + return self.channel.is_initialized async def setup_exchanges(self) -> None: self.tenant_exchange = await self.channel.declare_exchange( diff --git a/pyproject.toml b/pyproject.toml index d56ab3e..d97d1f8 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "pyinfra" -version = "3.2.0" +version = "3.2.1" description = "" authors = ["Team Research "] license = "All rights reseverd"