Retry for Asynchronous Generator (PEP 525)

[heri16]

Could we support retry for Asynchronous Generator?

import asyncio
import random
from tenacity import retry

@retry
async def ticker(delay, to):
    """Yield numbers from 0 to `to` every `delay` seconds."""
    for i in range(to):
        if random.randint(0, 10) > 1:
            raise IOError("Broken sauce, everything is hosed!!!111one")
        else:
            yield i
        await asyncio.sleep(delay)

async for i in ticker(1, 10):
    print(i)

See: PEP 525

[RonnyPfannschmidt]

the example looks simply impossible to do sane in the backend

[ashleystendel]

Hi! Why is this impossible? It would be great to have this support

[RonnyPfannschmidt]

Any retrying wrapper would lose the inner State of the generator,which would have to restart

In catastrophic scenarios this could mean yielding thousand's of elements instead of 10

[jd]

As noted in the comments, retrying a generator is inherently problematic — the wrapper would lose inner state and restart from scratch, potentially yielding duplicates. This limitation is now documented in #612.