Skip to content

Commit

Permalink
fix: changed condition in FutureStore.reject_all to �syncio.isfuture …
Browse files Browse the repository at this point in the history
…instead of isinstance to support futures from _asyncio module when debugging in pycharm
  • Loading branch information
jhonjohn committed Nov 21, 2024
1 parent 120965c commit 32ea028
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion aiormq/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 32ea028

Please sign in to comment.