Очистка после ожидания первой задачи Asyncio для выполнения: безопасно ли проглотить DecelledError при повышении задачи. ⇐ Python

[Anonymous]

У меня есть функция асинсио, которая порождает несколько задач, любая из которых может вернуть результат, и в этом случае мы хотим отключить все остальные.

Код: Выделить всё

all_tasks = [asyncio.create_task(ds.get() for ds in data_sources]
try:
done, pending = await asyncio.await(
all_tasks,
return_when=asyncio.FIRST_COMPLETED
)
for task in done:
if (ex := task.exception()):
raise ex
response = await task
# more handling here, but let's pretend it's just...
return response
finally:
for task in pending:
try:
task.cancel()
await task
except asyncio.CancelledError:
continue
ex = task.exception()
if ex is not None:
logger.warn("task failed", ex)
for task in done:
ex = task.exception()
if ex is not None:
logger.warn("task failed", ex)

Я здесь обеспокоен тем, что глотание DecelledError явно задокументировано как плохая практика в коде пользователя, с безопасным использованием, требующим вызывания uncancel () .
это на самом деле невыносимо? Что да, то, что нужно изменить, чтобы иметь эквивалентную функциональность без риска повреждения внутреннего состояния Асинсио? Хотите ждать только задачи первого для выполнения, и отменить других детей без пропаганды этой отмены родителю).

Подробнее здесь: https://stackoverflow.com/questions/796 ... to-swallow