observability-async-generator-hand-when-using-the-observe-decorator-on-a-function-tha-98fbec2c

THEN Patch the decorator to detect async generators via inspect.isasyncgen() and iterate over them with 'async for' to capture each yielded item, similar to the existing handling of sync generators with inspect.isgenerator(). In the async branch, if the result is an async generator, wrap it with a helper that updates the observation after each yield.

# Inside the observe decorator, after detecting async function:
if inspect.isasyncgen(result):
    async for item in result:
        # Update observation with item
        await langfuse_span_or_generation.update(output=item)
        yield item
else:
    # Handle normal async return