anti_dogpile.py

fut = None

async def antidogpile(coro, *args, **kwargs):
    nonolocal fut

    async def helper():
        nonlocal fut
        try:
            return await coro(*args, **kwargs)
        finally:
            fut = None

    if fut is None:
        fut = asyncio.shield(helper())
    return await fut