Improve cancellation semantics and unawaited tasks

omnilib / aioitertools

itertools and builtins for AsyncIO and mixed iterables

https://aioitertools.omnilib.dev

MIT License

240 stars 24 forks source link

Closed amyreese closed 2 years ago

amyreese commented 2 years ago

In asyncio.as_completed(), when timeouts happen, pending tasks are now cancelled.
In builtins.zip(), uses gather with return_exceptions=True to prevent leftover, unawaited tasks.
Creates a fresh event loop for each test case, and closes that after test completion, to help debug and uncover pending tasks.

Fixes: #67