Fix async streaming support for Agno Team.arun() - Resolves #1262

[devin-ai-integration]

📥 Pull Request

📘 Description

Fixes #1262 - Resolves TypeError: 'async for' requires an object with __aiter__ method, got coroutine when using Agno v2 async streaming with AgentOps instrumentation.

Root Cause: When Team.arun(stream=True) is called, it returns an async generator directly. The previous wrapper was defined as async def, which caused Python to wrap the returned async generator in a coroutine, breaking async for loops.

Solution:

1. Added AsyncStreamingResultWrapper class that properly implements the async iteration protocol (__aiter__ and __anext__)
2. Changed create_team_async_wrapper from async def wrapper to def wrapper - this allows async generators to be returned directly without coroutine wrapping
3. Added inspect.isasyncgen() checks to detect and properly wrap async generators
4. Updated create_streaming_agent_async_wrapper to check for __aiter__ before __iter__ for correct async detection

🧪 Testing

Created test script examples/agno/test_async_streaming_team.py that reproduces the original issue:

• ✅ Async iteration successfully started (no more coroutine error)
• ✅ Received RunStartedEvent confirming async streaming works
• ✅ Linting passed: ruff check and ruff format
• ⚠️ Hit OpenAI quota during full test (unrelated to fix)

🔍 Human Review Checklist

Critical items:

1. Verify inspect.isasyncgen(result) is the correct check for detecting async generators at runtime
2. Confirm the synchronous wrapper pattern (non-async function returning async generator) is correct
3. Review cleanup logic in AsyncStreamingResultWrapper.__anext__ - does span cleanup happen correctly in all cases?
4. Check if other async wrappers (e.g., create_workflow_async_wrapper) need similar fixes

Additional considerations:
5. Verify context attachment/detachment is correct and doesn't leak contexts
6. Consider if this pattern change should have automated tests added

---

Session Info:

• Devin session: https://app.devin.ai/sessions/bbe4d6d6f4954f82ba3ed1ae15ce6667
• Requested by: Alex (meta.alex.r@gmail.com) / @areibman

[devin-ai-integration]

🤖 Devin AI Engineer

I'll be helping with this pull request! Here's what you should know:

✅ I will automatically:

• Address comments on this PR. Add '(aside)' to your comment to have me ignore it.
• Look at CI failures and help fix them

Note: I can only respond to comments from users who have write access to this repository.

⚙️ Control Options:

• Disable automatic comment and CI monitoring