asyncio CancelledError and KeyboardInterrupt

by

task.cancel() itself doesn’t finish the task: it just says to task that CancelledError should be raised inside it and returns immediately. You should call it and await while task would be actually cancelled (while it’ll raise CancelledError).

You also shouldn’t suppress CancelledError inside task.

Read this answer where I tried to show different ways of working with tasks. For example to cancel some task and await it cancelled you can do:

from contextlib import suppress


task = ...  # remember, task doesn't suppress CancelledError itself

task.cancel()  # returns immediately, we should await task raised CancelledError.

with suppress(asyncio.CancelledError):
    await task  # or loop.run_until_complete(task) if it happens after event loop stopped

# Now when we awaited for CancelledError and handled it, 
# task is finally over and we can close event loop without warning.

More Related Contents:

  1. When to use and when not to use Python 3.5 `await` ?
  2. “Fire and forget” python async/await
  3. Asynchronous method call in Python?
  4. How to limit concurrency with Python asyncio?
  5. multiprocessing vs multithreading vs asyncio in Python 3
  6. How to use asyncio with existing blocking library?
  7. Asyncio.gather vs asyncio.wait
  8. Timeout for python coroutines
  9. Simplest async/await example possible in Python
  10. “Asyncio Event Loop is Closed” when getting loop
  11. Can an asyncio event loop run in the background without suspending the Python interpreter?
  12. How do I run Python asyncio code in a Jupyter notebook?
  13. Combine awaitables like Promise.all
  14. What kind of problems (if any) would there be combining asyncio with multiprocessing?
  15. How to test Python 3.4 asyncio code?
  16. How to use ‘yield’ inside async function?
  17. How to call an async function without await?
  18. asyncio: Is it possible to cancel a future been run by an Executor?
  19. Mocking async call in python 3.5
  20. Why can I only use the await keyword inside of async function?
  21. How to do multiprocessing in FastAPI
  22. How to set class attribute with await in __init__
  23. What’s the correct way to clean up after an interrupted event loop?
  24. aiohttp: set maximum number of requests per second
  25. How can I await inside future-like object’s __await__?
  26. Prompt for user input using python asyncio.create_server instance
  27. Why am I getting NotImplementedError with async and await on Windows?
  28. “asyncio.run() cannot be called from a running event loop” when using Jupyter Notebook
  29. Exception event loop is closed with aiohttp and asyncio in python 3.8
  30. how to add a coroutine to a running asyncio loop?

Leave a Comment