Я использую asyncio.gather для параллельного запуска нескольких сопрограмм. Когда одна сопрограмма вызывает исключение, я ожидаю, что остальные задачи будут отменены. Однако они продолжают работать.
import asyncio
async def worker(id):
await asyncio.sleep(1)
if id == 2:
raise ValueError("Failing task")
return id
async def main():
tasks = [worker(i) for i in range(5)]
try:
await asyncio.gather(*tasks)
except Exception as e:
print("Error:", e)
asyncio.run(main())
Подробнее здесь: https://stackoverflow.com/questions/798 ... task-fails
Мобильная версия