From 73165044ce40bf0f724f5d81bc5bd117b690d09b Mon Sep 17 00:00:00 2001 From: jhonjohn Date: Thu, 21 Nov 2024 07:21:20 +0200 Subject: [PATCH] fix: changed condition in FutureStore.reject_all to asyncio.isfuture instead of isinstance to support futures from _asyncio module when debugging in pycharm --- aiormq/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aiormq/base.py b/aiormq/base.py index b8bf9bd..b220207 100644 --- a/aiormq/base.py +++ b/aiormq/base.py @@ -57,7 +57,7 @@ async def reject_all(self, exception: Optional[ExceptionType]) -> None: if isinstance(future, TaskWrapper): future.throw(exception or Exception) tasks.append(future) - elif isinstance(future, asyncio.Future): + elif asyncio.isfuture(future): future.set_exception(exception or Exception) if tasks: