def gather(futures, consume_exceptions=True):

    # from the asyncio docs: "If return_exceptions is True, exceptions
    # in the tasks are treated the same as successful results, and
    # gathered in the result list; otherwise, the first raised
    # exception will be immediately propagated to the returned
    # future."
    return asyncio.gather(*futures, return_exceptions=consume_exceptions)
Return a reference to the currently executing Async job object and it's
dataset/ETHPy150Open crossbario/txaio/txaio/aio.py/gather--crossover with--dataset/ETHPy150Open Workiva/furious/furious/context/__init__.py/get_current_async_with_context