Skip to content

Commit 1a78d7e

Browse files
authored
Use handle_stream.stream_output() in the CLI (#1376)
1 parent 1caeda0 commit 1a78d7e

File tree

1 file changed

+3
-5
lines changed
  • pydantic_ai_slim/pydantic_ai

1 file changed

+3
-5
lines changed

pydantic_ai_slim/pydantic_ai/_cli.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515

1616
from pydantic_ai.agent import Agent
1717
from pydantic_ai.exceptions import UserError
18-
from pydantic_ai.messages import ModelMessage, PartDeltaEvent, TextPartDelta
18+
from pydantic_ai.messages import ModelMessage
1919
from pydantic_ai.models import KnownModelName, infer_model
2020

2121
try:
@@ -222,10 +222,8 @@ async def ask_agent(
222222
status.stop() # stopping multiple times is idempotent
223223
stack.enter_context(live) # entering multiple times is idempotent
224224

225-
async for event in handle_stream:
226-
if isinstance(event, PartDeltaEvent) and isinstance(event.delta, TextPartDelta):
227-
content += event.delta.content_delta
228-
live.update(Markdown(content, code_theme=code_theme))
225+
async for content in handle_stream.stream_output():
226+
live.update(Markdown(content, code_theme=code_theme))
229227

230228
assert agent_run.result is not None
231229
return agent_run.result.all_messages()

0 commit comments

Comments
 (0)