observability-decorator-async-supp-when-using-observe-on-an-async-generator-function--c1c9780c

THEN Add detection of async generator functions using inspect.isasyncgenfunction and inspect.isasyncgen. Wrap async generators in a custom async generator that captures and yields output, updating the observation appropriately (similar to the existing sync generator handling).

if inspect.isasyncgenfunction(func):
    # Wrap async generator to capture output
    async def wrapper(*args, **kwargs):
        gen = func(*args, **kwargs)
        # ... iterate and update observation
        async for item in gen:
            yield item
        observation.update(output=accumulated_output)
    return wrapper