scriptoriumadmin/litellm
1
0
Fork 0
mirror of https://github.com/BerriAI/litellm.git synced 2026-09-15 23:31:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 165

fix(v2 managed agents): type stream_events as a sync def returning AsyncIterator

Browse source
This commit is contained in:
Ishaan Jaffer 2026-05-07 13:53:06 -07:00
parent 594fb905b4
commit 830fa3b16b
No known key found for this signature in database
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
litellm/managed_agents/adapters/base.py
View file

@ -75,7 +75,7 @@ class SandboxAdapter(Protocol):
"""
...
async def stream_events(
def stream_events(
self,
sandbox_url: str,
opencode_session_id: str,
@ -88,6 +88,14 @@ class SandboxAdapter(Protocol):
normalized `(event_type, data_dict)` tuples per contract §7. Events
not in the translation table are dropped. Raises
`SandboxUnreachableError` on connect/timeout failures.
NOTE: this is declared as a regular ``def`` returning an
``AsyncIterator`` because concrete adapters implement it as an
``async def ... yield`` (async generator). An ``async def f() ->
AsyncIterator[T]: yield x`` is typed as ``AsyncIterator[T]``,
not ``Coroutine[..., AsyncIterator[T]]`` — declaring the
protocol method as ``async def`` would force callers to ``await``
it before iterating, which is the wrong runtime shape.
"""
...