async def METHOD_NAME(*args, **kwargs):
    for _ in range(15):  # super simple retry-mechanism
        try:
            return await outer(*args, **kwargs)
        except (neo4j_exceptions.DriverError,
                neo4j_exceptions.Neo4jError) as e:
            if not e.is_retryable():
                raise
            await asyncio.sleep(1.5)