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

[devin-ai-integration]

📥 Pull Request

📘 Description

Fixes #1262 - Resolves TypeError when using async for with Agno Team.arun() streaming.

Root Cause: When Team.arun(stream=True) is called, it returns an async generator directly (not a coroutine). The team async wrapper was defined as async def, which wrapped the returned async generator in a coroutine, causing the error: 'async for' requires an object with __aiter__ method, got coroutine.

Solution:

1. Added AsyncStreamingResultWrapper class that properly implements __aiter__ and __anext__ for async generator wrapping
2. Changed create_team_async_wrapper from async def to regular def to prevent wrapping async generators in coroutines
3. Added inspect.isasyncgen() checks to detect and handle async generators correctly
4. Updated create_streaming_agent_async_wrapper to check for __aiter__ before __iter__

Changes (Core Fix):

• agentops/instrumentation/agentic/agno/instrumentor.py: Added AsyncStreamingResultWrapper class and modified team/agent async wrappers to properly handle async generators

🧪 Testing

Created test script test_async_streaming_team.py that reproduces the issue:

• ✅ Successfully started async iteration (no more coroutine error)
• ✅ Received RunStartedEvent showing async streaming is working
• ⚠️ Hit OpenAI quota limit during test (unrelated to fix)
• ✅ Linting passed: ruff check and ruff format both pass

Evidence of Fix:

• No more RuntimeWarning: coroutine 'create_team_async_wrapper.<locals>.wrapper' was never awaited
• No more TypeError: 'async for' requires an object with __aiter__ method
• Async iteration successfully started with proper event streaming

---

⚠️ CRITICAL: Unrelated Changes Detected

This PR contains many unrelated files that should NOT be included:

• .envrc
• Multiple setup guides (SETUP_GUIDE.md, local_supabase_linux.md, local_clickhouse_setup.md)
• Memori integration documentation
• Environment file updates
• README updates

Action Required: These files should be excluded from this PR and submitted separately if needed.

---

🔍 Human Review Checklist

High Priority:

1. ⚠️ Verify ONLY the instrumentor.py changes should be merged - exclude all unrelated files
2. Confirm AsyncStreamingResultWrapper.__anext__ correctly maintains span context
3. Verify changing create_team_async_wrapper from async def to def is the correct solution
4. Check that inspect.isasyncgen() is the right check for detecting async generators

Medium Priority:
5. Verify the fix works for both Team.arun() and Agent.arun() streaming
6. Confirm span cleanup happens correctly in StopAsyncIteration case
7. Check if similar issues exist in other async wrappers (workflow, team_internal)

---

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

[devin-ai-integration]

Closing this PR due to unrelated files being included. Opening a clean PR with only the fix.