Учитывая группу задач и количество запущенных задач для каждой группы задач, если какая-либо из задач вызывает ошибку, остальные задачи в группе будут отменены.
Если некоторые из этих задач должны выполнять очистку после отмены, тогда как можно обнаружить, что в задаче она отменяется?
Я надеялся, что в задаче возникнет какое-то исключение, но это не так:
script.py:
import asyncio
class TerminateTaskGroup(Exception):
"""Exception raised to terminate a task group."""
async def task_that_needs_to_cleanup_on_cancellation():
try:
await asyncio.sleep(10)
except Exception:
print('exception caught, performing cleanup...')
async def err_producing_task():
await asyncio.sleep(1)
raise TerminateTaskGroup()
async def main():
try:
async with asyncio.TaskGroup() as tg:
tg.create_task(task_that_needs_to_cleanup_on_cancellation())
tg.create_task(err_producing_task())
except* TerminateTaskGroup:
print('main() termination handled')
asyncio.run(main())
При выполнении мы видим, что в Task_that_needs_to_cleanup_on_cancellation() не возникает никаких исключений:
$ python3 script.py
main() termination handled
Подробнее здесь: https://stackoverflow.com/questions/791 ... task-group
Как обнаружить отмену задачи по группе задач ⇐ Python
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение