Kas notiek asyncio.gather(), ja vienā no uzdevumiem rodas kļūda? Kā nodrošināt, lai izņēmumi netiktu zaudēti?

Если в одной из задач, переданных в asyncio.gather(), возникает исключение, то по умолчанию gather прерывает выполнение и сразу же выбрасывает это исключение. При этом остальные задачи могут быть отменены, и их результаты не будут возвращены.

Чтобы исключения не терялись и можно было получить результаты всех задач вместе с информацией об ошибках, можно использовать параметр return_exceptions=True. В этом случае gather вернёт список результатов, где вместо исключения будет сам объект исключения, который можно обработать отдельно.

Пример:

import asyncio

async def task(n):
    if n == 2:
        raise ValueError("Ошибка в задаче 2")
    return n * 2

async def main():
    results = await asyncio.gather(
        task(1),
        task(2),
        task(3),
        return_exceptions=True
    )
    for i, result in enumerate(results, 1):
        if isinstance(result, Exception):
            print(f"Задача {i} завершилась с ошибкой: {result}")
        else:
            print(f"Задача {i} вернула результат: {result}")

asyncio.run(main())

Таким образом, return_exceptions=True позволяет не терять исключения и обрабатывать их после выполнения всех задач.