We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 83d7bb6 commit 6ad18ccCopy full SHA for 6ad18cc
src/google/adk/cli/adk_web_server.py
@@ -1558,8 +1558,17 @@ async def event_generator():
1558
yield f"data: {sse_event}\n\n"
1559
except Exception as e:
1560
logger.exception("Error in event_generator: %s", e)
1561
- # You might want to yield an error event here
1562
- yield f'data: {{"error": "{str(e)}"}}\n\n'
+ # Yield a proper Event object for the error
+ error_event = Event(
1563
+ author="system",
1564
+ content=types.Content(
1565
+ role="model", parts=[types.Part(text=f"Error: {e}")]
1566
+ ),
1567
+ )
1568
+ yield (
1569
+ "data:"
1570
+ f" {error_event.model_dump_json(by_alias=True, exclude_none=True)}\n\n"
1571
1572
1573
# Returns a streaming response with the proper media type for SSE
1574
return StreamingResponse(
0 commit comments