async def METHOD_NAME(driver_: neo4j.AsyncDriver, n=10):
    signals = [Signal() for _ in range(n)]
    await asyncio.gather(
        *(handle_session(driver_.session(), signals[i]) for i in range(n)),
        handle_signals(signals),
        return_exceptions=True,
    )