async def METHOD_NAME(driver_: neo4j.AsyncDriver):
    async with driver_:
        work_loads = (session_handler(driver_.session())
                      for _ in range(pool_size * 4))
        res = await asyncio.gather(*work_loads, return_exceptions=True)
        for r in res:
            if isinstance(r, Exception):
                raise r