"j|SSKJr SSKJrJrJrJrJrJ r SSK J r J r SSK Jr SSKJrJrJr SSKJr SSKJr SSKJr SS KJrJrJrJrJr SS KrSS KJ r SS K!J"r" S SK#J$r$J%r%J&r'J(r( S SK)J*r* S SK+J,r,J-r-J.r.J/r/J0r0J1r1J2r2 S SK3J4r4J5r5J6r6 S SK7J8r8 S SK&J9r9J:r: S SK;JJ?r? S SK@JArA S SKBJCrCJDrD \(a S SKEJFrF S SKGJHrH SrI\"SS9"SS\\4\<455rJ\"SS 9"S!S"\\4\<455rK"S#S$\\4\<45rL\"SS%9"S&S'\\<55rMS*S(jrNS+S)jrOg ),) annotations)AsyncGenerator AsyncIterator AwaitableCallableIterableIterator)AbstractAsyncContextManageraclosing)deepcopy) dataclassfieldreplace)datetime)Decimal) TracebackType) TYPE_CHECKINGAnyGenericcastoverloadN)ValidationError)Self)_utils exceptionsmessagesmodels)best_effort_price)OutputDataT_inv OutputSchemaOutputValidatorOutputValidatorFuncTextOutputSchemarun_image_process_hooksrun_output_with_hooks) AgentDepsT RunContextdispatch_event_stream)SyncStreamBridge)AgentStreamEventModelResponseStreamEvent) OutputDataT ToolOutput) ToolManager)DeferredToolRequests)RunUsage UsageLimits)AbstractCapabilityAgentRunResult)r-r r.r#StreamedRunResultSyncT)kw_onlyc\rSrSr%S\S'S\S'S\S'S\S 'S \S 'S \S 'S\S'S\S'\"SSS9rS\S'\"\SS9rS\S'\"SSS9r S\S'\"SS9r S\S'\"SSS9r S\S '\"\ RSS!9rS"\S#'\"S$SS!9rS%\S&'S'rS(S).SCS*jjrS(S).SDS+jjrSS(S,.SES-jjrSFS.jrSFS/jr\SGS0j5r\SHS1j5r\SHS2j5r\SIS3j5r\SJS4j5r\SKS5j5r\SLS6j5rSMS7jrSNS8jrSS9.SOS:jjr SPS;jr!SS(S,.SES<jjr"SQS=jr#SFS>jr$SRS?jr%SSS@jr&STSAjr'SBr(g)U AgentStream3models.StreamedResponse_raw_stream_responsezOutputSchema[OutputDataT]_output_schemazmodels.ModelRequestParameters_model_request_parametersz.list[OutputValidator[AgentDepsT, OutputDataT]]_output_validatorszRunContext[AgentDepsT]_run_ctxUsageLimits | None _usage_limitsToolManager[AgentDepsT] _tool_managerzAbstractCapability[AgentDepsT]_root_capabilityNF)defaultreprz*Callable[[], dict[str, Any] | None] | None_metadata_getterz$Callable[[], list[AgentStreamEvent]]_event_stream_buffer_getterrFinitz&AsyncIterator[AgentStreamEvent] | None_events_iteratorrKr1_initial_run_ctx_usagezOutputDataT | None_cached_output)default_factoryrKz anyio.Lock _anext_lockc:[[R"5$N)setanyio CancelScopeO/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_ai/result.pyAgentStream.EsUM^M^I_IarXzset[anyio.CancelScope] _pull_scopescL[URR5UlgrS)r r@usagerNselfs rY __post_init__AgentStream.__post_init__Gs&.t}}/B/B&C#rX皙? debounce_bycB# URb[UR57v gSnURUS9ShvN nURRb!U(aUR UR :XaMCUnUR USS9IShvN 7v McN^N ![[R4a Mf=f URRbDURnUR U5IShvN Ul[UR57v gg7f)z4Asynchronously stream the (validated) agent outputs.NrdT allow_partial) rOr stream_responser<final_result_eventpartsvalidate_response_outputrr ModelRetryresponse)r`re last_responserns rY stream_outputAgentStream.stream_outputJs     *4../ / 8< "22{2K (((;;C(..M4G4G"G$M  99(RV9WWW X#Z%:%:;  L  $ $ 7 7 C}}H )-(E(Eh(O"O"OD 4../ / Dsb8DCBC=DB!BB!DCB!!B?;D>B??;D:C=;$Dc# URnURS:Xa/URHnUR5(dMU7v O [R "UR 5U5IShvN nUShvN nUR7v MN N SSS5IShvN O!,IShvN (df  O=fUR7v g7f)uAsynchronously stream the (unvalidated) model responses for the agent. Yields `ModelResponse` snapshots — `state='incomplete'` while streaming is in flight, followed by one final `state='complete'` snapshot (or `'interrupted'` if `cancel()` was called). If the underlying response already has accumulated content when this is called, a pre-stream yield surfaces it before iteration begins. incompleteN)rnstaterk has_contentrgroup_by_temporal_model_response_events)r`remsgpart group_iter_itemss rYriAgentStream.stream_responsegsmm 99 $ ##%%I" ++D,G,G,I;WW[e * $fmm#X $ XWWWWWmmsq?C2C7B8C;B/>BBBB/CBB/ C(B+)C/C5B8 6 CCdeltarec # [UR[5(d[R"S5e[UR [ 5(aUR 7v gU(a URSUS9ShvN nU7v MURSUS9ShvN nURH/nURU[URSS95IShvN nM1 U7v MONj gNNN g7f)uStream the text result as an async iterable. !!! note [`TextOutput`][pydantic_ai.output.TextOutput] functions are not applied — use [`stream_output()`][pydantic_ai.result.AgentStream.stream_output] instead. Result validators will NOT be called on the text result if `delta=True`. Args: delta: if `True`, yield each chunk of text as it is received, if `False` (default), yield the full text up to the current point. debounce_by: by how much (if at all) to debounce/group the response chunks by. `None` means no debouncing. Debouncing is particularly important for long structured responses to reduce the overhead of performing validation as each token is received. 2stream_text() can only be used with text responsesNTr}Fpartial_output) isinstancer=r$r UserErrorrOstr_stream_response_textr?validaterr@)r`r~retext validators rY stream_textAgentStream.stream_text|s$--/?@@&&'[\ \ d))3 / /%% %  "88tQ\8] d "88uR]8^ d!%!8!8I!*!3!3D'$--`d:e!ffD"9  ] f_s`AC/C-C/C7C5"C1#C5&7C7C3C7-C//C71C53C75C7cT# URR5IShvN gN7f)awCancel local stream consumption and request provider shutdown. Whether this stops remote generation or closes the underlying transport depends on the provider SDK. This stops only the current model response; the run continues. To end the whole run, use [`AgentRun.cancel()`][pydantic_ai.run.AgentRun.cancel] or [`RunContext.cancel()`][pydantic_ai.tools.RunContext.cancel]. N)r<cancelr_s rYrAgentStream.cancels''..000s (&(c,# UShvN nM N g7f)z>Consume all remaining events from the stream, discarding them.NrWr`_s rYdrainAgentStream.drains !  tsc.URR$)5Whether the stream has been cancelled via `cancel()`.)r< cancelledr_s rYrAgentStream.cancelled((222rXc`URRceURR$(The unique identifier for the agent run.)r@run_idr_s rYrAgentStream.run_ids*}}##///}}###rXc`URRceURR$?The unique identifier for the conversation this run belongs to.)r@conversation_idr_s rYrAgentStream.conversation_ids*}},,888}},,,rXchURbUR5$URR$7Metadata associated with this agent run, if configured.)rHr@metadatar_s rYrAgentStream.metadatas/  ,((* *}}%%%rXc6URR5$)z&Get the current state of the response.)r<getr_s rYrnAgentStream.responses((,,..rXcURURR-nURRRc[ URRUR R UR RUR RUR RS9nUb0UR=(d [S5UR-UlU$)pReturn the usage of the whole run. !!! note This won't return the full usage until the stream is finished. ) model_nameprovider_api_url provider_namegenai_request_timestampr) rNr<r^costrrnr provider_urlr timestampr total_price)r`r^prices rYr^AgentStream.usages++d.G.G.M.MM  $ $ * * / / 7%))//==33!%!;!;"mm99(, (?(? E #jj6GAJ%:K:KK  rXc.URR$"Get the timestamp of the response.)r<rr_s rYrAgentStream.timestamprrXc# URb[UR5$UShvN nM N URUR5IShvN Ul[UR5$7f)z=Stream the whole response, validate the output and return it.N)rOr rlrnrs rY get_outputAgentStream.get_outputsh    *D//0 0 !  t%)$A$A$--$PPP++,,s+%A3424A34A3AA3cURc'UR(a[R"S5eURR n[ [UR5Ub UR4$S4$)aBThe validated output and the name of the output tool that produced it, if any. Every path that consumes a stream to the end validates the response and caches the result, so by then `_cached_output` holds it. Cancelling does not: it marks the stream complete without a final response, and there is no output to settle on. NzThe stream was cancelled before it produced an output, so this run has no settled result. The messages recorded up to the interruption are still available from `all_messages()`.) rOrrrr<rjrr- tool_name)r`rjs rY_settled_outputAgentStream._settled_outputsx    &4>>&&$  "66II d11 2,>,J  ( (  PT  rXrgc `^ # URRnUc[R"S5eURm UR R (anT bk[U 4SjUR5S5nUc[R"ST <35eURRUUR USS9IShvN $[URUR5=n(aAUR R(d[R"S5e[[U5$UR R (a6UR"(a%UR%UR"SUS 9IShvN $UR R&=n(aS nUR(HUn[+U[,R.5(aXxR0- nM2[+U[,R25(dMSS nMW [5UR6US 9n [9UUU UR:UR USUR<S 9IShvN $[R"S 5eGNNN![>[R@4a$n U(d[R"S5U eeSn A ff=f7f)%Validate a structured result message.Nz'Invalid response, unable to find outputc3J># UHoRT:XdMUv M g7frS)r).0ryoutput_tool_names rY 7AgentStream.validate_response_output..s_&8dNNN^<^TT&8s# #z/Invalid response, unable to find tool call for F)schemarhwrap_validation_errorszA deferred tool call was present, but `DeferredToolRequests` is not among output types. To resolve this, add `DeferredToolRequests` to the list of output types for this agent.rrgr)r run_context capabilityrrhroutput_validatorsz/Invalid response, unable to process text outputzZOutput validation failed during streaming, and retries are not supported in `run_stream()`)!r<rjrUnexpectedModelBehaviorrr=toolsetnext tool_callsrDhandle_output_tool_call_get_deferred_tool_requestsallows_deferred_toolsrrr- allows_imageimages_validate_image_outputtext_processorrkr _messagesTextPartcontentNativeToolCallPartrr@r&rEr?rrm) r`messagerhrj tool_calldeferred_tool_requestsrrryrun_ctxers @rYrl$AgentStream.validate_response_outputs|"66II  %445^_ _-776 ""**/?/K _g&8&8_ $$<<IJZI]^"//GG.."/+0 H ,GwGYGY[_[m[m+nn'n**@@$..JK)?@@$$11gnn!889JZg8hhh#'#6#6#E#EEE#MMD!$ (:(:;; ,#D)*F*FGG " *"$-- N2" '#44.."/+0&*&=&=   !88EIi  !6!67   88p   sI-J.A:I-A I- I+ I-J.I-)I-+I--J+J&&J++J.c # [URUS9n[[[ UUR UUR SURS9IShvN 5$N7f)zARun process hooks (including output validators) for image output.rF)rrrrrN)rr@rr-r%rEr=r?)r`imagerhrs rYr"AgentStream._validate_image_outputIs[$-- F )00#**',"&"9"9     sAAA  Ach^^^# SU4SjjmSUU4Sjjn[U"55IShvN nU(aUShvN nU7v M/nUShvN nURU5 SRU57v M0NQNA ON1 SSS5IShvN g!,IShvN (df  g=f7f)z1Stream the response as an async iterable of text.c<># TRn[UR5HJup[U[R 5(dM&UR (dM9UR U47v ML SnTShvN n[U[R5(aw[UR[R 5(aNURR (a3URnURR UR47v M[U[R5(ax[UR[R5(aOURR(a4URnURRUR47v GM6[U[R5(dGMX[UR[R5(dGMUcGMSUR47v SnGMGN g7f)Nz )rn enumeraterkrrrrPartStartEventryindexPartDeltaEventr~ TextPartDelta content_deltar)rxirylast_text_indexeventr`s rY_stream_text_deltas_ungroupedHAgentStream._stream_response_text.._stream_text_deltas_ungrouped`s_--C$SYY/dI$6$677DLLL,,/)0+/O# +eui&>&>??"5::y/A/ABB **&+kkO**,,ekk99ui&>&>??"5;; 0G0GHH 11&+kkO++33U[[@@ui&>&>??"5::y/K/KLL'3!%++--&*O- +tsIAH HH7H;H<H?E H'H;HHHHc 0># [R"T"5T5IShvN nUShvN nSRUVVs/sHup#UPM snn57v M4N:N1s snnf SSS5IShvN g!,IShvN (df  g=f7f)Nr)rrvjoin)rzitemsrrrres rY_stream_text_deltas>AgentStream._stream_response_text.._stream_text_deltassu//0M0OQ\]]ak#-E%''U"CUzw7U"CDD^E"C$.^]]]]]sp!BABA<A)A!A)A<A# A<B!A)#A<* B5A86B<BB  BBNr)returnzAsyncIterator[tuple[str, int]])rzAsyncGenerator[str, None])r appendr)r`r~rer deltas_iterrdeltasrs` ` @rYr!AgentStream._stream_response_textXs +D E E /122k"-$J%'"-*$MM$'''&/)3+ *+322222s&B2A=B2 BBA?B B BBB(B=B2?BBBB B2BB2B/B!  B/+B2c H^TRcz[TRTRU4Sj5n[ TR R TR[TRTRU55S95TlTRTR5$)z}Stream [`AgentStreamEvent`][pydantic_ai.messages.AgentStreamEvent]s, interleaving events emitted into the run's event buffer.cJ>TRTRR-$rS)rNr<r^r_srYrZ'AgentStream.__aiter__..s33d6O6O6U6UUrX)stream) rL#_get_usage_checking_stream_responser<rBaiterrEwrap_run_event_streamr@r) _events_iter _pull_shared)r` base_iters` rY __aiter__AgentStream.__aiter__s  (<))""UI%*%%;;MM*? tO`O`ajOk*l<%D !   !6!677rXc# URnUbURHnUR5 M [R"SS9 UR IShvN [ R"U5IShvN SSS5IShvN SSS5 ggN<N N!,IShvN (df  N'=f!,(df  g=f7f)aWClose the event stream when a consumer walks away before exhausting it. The event iterator owns the capability chain, which can otherwise stay suspended with resources held, like a `ProcessEventStream` handler task parked on its receive stream. Any in-flight shared pull is cancelled and drained before the iterator is closed. The close is shielded because graph teardown can run inside an already-cancelled scope. The closed iterator is kept in place rather than discarded, so a later `__aiter__()` ends immediately instead of building a second chain (and a second handler) over a spent stream. NT)shield)rLr\rrUrVrQraclose_if_supported)r`events_iteratorscopes rY aclose_eventsAgentStream.aclose_eventss//  &** +""$/+++ 44_EEE,+0/ ',E,+++0/sxAC B7BB7B8B9B= B7B B7 CB7BB7B4 #B&$ B4 0B77 CCc# URIShvN Sn[R"5nURR U5 [ U5IShvN nURRU5 SSS5 WR(aSSS5IShvN gUceSSS5IShvN W7v MNNj![ a7 URRU5 SSS5 SSS5IShvN gf=f!URRU5 f=f!,(df  N=fNN!,IShvN (df  N=f7frS) rQrUrVr\addanextStopAsyncIterationdiscard cancel_called)r`r rrs rYrAgentStream._pull_shareds'''15&&(E%%))%09#*/*@$@E))11%8)&&(''(((('K' %A1#"))11%8)(''#))11%8)(('''sECEED-C CC "D->E E#D>$E)E. E9E: EC  D D D-/E7 EDE D  D  D**D-- D; 7E>EEEE EEc# UShvN n[U[R[R-[R-[R -5(dM]U7v MdN_ g7f)zcIterate only the model response stream events, dropping events emitted into the run's event buffer.N)rrrr PartEndEventFinalResultEvent)r`rs rYrw"AgentStream._model_response_eventssb %((**+((),,-  4s,A-A+A)A+AA-"A-)A++A-c# UR5=n(a-URS57v UR5=n(aM-[U5IShvN nU7v M_N ![a gf=f7f)Nr)rIpoprr)r`rbufferrs rYrAgentStream._events_itersv!<<>>&>jjm#!<<>>&> #I..K/%  s<AA5 A%A#A%A5#A%% A2/A51A22A5)rOrLrNre float | NonerzAsyncIterator[OutputDataT]rer!rz&AsyncIterator[_messages.ModelResponse]r~boolrer!rzAsyncIterator[str]rNonerr$rrrzdict[str, Any] | Noner_messages.ModelResponserr1rrrr-)rztuple[OutputDataT, str | None]rr+rhr$rr-)rz_messages.BinaryImagerhr$rr-)rAsyncIterator[AgentStreamEvent])r r0rr0)r'AsyncIterator[ModelResponseStreamEvent])rr1rr0))__name__ __module__ __qualname____firstlineno____annotations__rrHlistrIrLrNrOrULockrQr\rarprirrrpropertyrrrrrnr^rrrrlrrrrrrwr__static_attributes__rWrXrYr9r93s11--<<FF$$%%**44CHQU\aCb@bHMVZafHg!Eg?DTX]?^<^',%'8H8).t%)HN&H#EJJUKKK+0Aahm+nL(nDBE0:DG*27TW D 1 33$$ -- && //,33 - (JO@.@BF@ @D  %#:*:*3?:* :*x8(F(*  rXr9FrMcP\rSrSr%SrS\S'S\S'SrS\S 'SrS \S 'SrS \S '\ "SSS9r S\S'\ S/Sj5r \ S0Sj5r S1S2Sjjr \ S3Sj5rSS.S4SjjrSS.S5SjjrSS.S4SjjrSS.S5SjjrSS.S6SjjrSSS.S7SjjrSS.S8S jjrS9S!jr\ S:S"j5r\ S;S#j5r\ SS&j5r\ S>S'j5rSS(.S?S)jjrS@S*jrSASBS+jjrSCS,jr \ SDS-j5r!S.r"g)EStreamedRunResultizFResult of a streamed run that returns structured data via a tool call.list[_messages.ModelMessage] _all_messagesint_new_message_indexN+AgentStream[AgentDepsT, OutputDataT] | None_stream_response$Callable[[], Awaitable[None]] | None _on_complete"AgentRunResult[OutputDataT] | None _run_resultFrJr$ is_completecgrSrW)r` all_messagesnew_message_indexri on_completes rY__init__StreamedRunResult.__init__rXcgrSrW)r`rIrJ run_results rYrLrM rNrXcNXlX lX0lX@lXPlSUlgrS)r>r@rBrDrF_traceparent_value)r`rIrJrirKrPs rYrLrMs/*"3 /'%.2 rXc SSKJn SSKJn UR=nbU$UR bUR (d[R"S5eUR R5upEU"UUU"URURURURURS9URUR S9$[#S5e)uThis run as an [`AgentRunResult`][pydantic_ai.run.AgentRunResult], once the stream has finished. A `StreamedRunResult` reads its values off the stream that is producing them, so it lives only as long as that stream does. `AgentRunResult` is the settled form of the same run — the same output, messages, usage and IDs — and it has a [serialized shape](../message-history.md#storing-complete-run-results) you can store and load. Reach for this to hand the run to code that outlives the stream. Raises: UserError: If the stream hasn't finished, or was cancelled before producing an output, so the run has no settled output to settle on. r)GraphAgentStater4zThe run is still streaming, so it has no settled result yet. Await `stream_output()`, `stream_text()`, `stream_response()` or `get_output()` first.)message_historyr^rrr)output_output_tool_name_stater@rR)No stream response or run result provided) _agent_graphrTrunr5rFrBrGrrrr>r^rrrr@rR ValueError)r`rTr5rPrVrs rYresultStreamedRunResult.result*s 2'** *J 7   " " .## **T(,'<'<'L'L'N $F!"2&$($6$6**;;$($8$8!]] $(#:#:#'#:#:  HI IrXoutput_tool_return_contentc6Ub [S5eUR$)aReturn the history of _messages. Args: output_tool_return_content: The return content of the tool call to set in the last message. This provides a convenient way to modify the content of the output tool call if you want to continue the conversation and want to set the response to the output tool call. If `None`, the last message will not be modified. Returns: List of messages. zISetting output tool return content is not supported for this result type.)NotImplementedErrorr>r`r`s rYrIStreamedRunResult.all_messagesTs" & 1%&qr r!!!rXcZ[RRURUS95$)aReturn all messages from [`all_messages`][pydantic_ai.result.StreamedRunResult.all_messages] as JSON bytes. Args: output_tool_return_content: The return content of the tool call to set in the last message. This provides a convenient way to modify the content of the output tool call if you want to continue the conversation and want to set the response to the output tool call. If `None`, the last message will not be modified. Returns: JSON bytes representing the messages. r_)rModelMessagesTypeAdapter dump_jsonrIrcs rYall_messages_json#StreamedRunResult.all_messages_jsone/11;;   9S  T  rXc:URUS9URS$)Return the messages produced during this run. Messages provided via `message_history` and messages from older runs are excluded. Args: output_tool_return_content: The return content of the tool call to set in the last message. This provides a convenient way to modify the content of the output tool call if you want to continue the conversation and want to set the response to the output tool call. If `None`, the last message will not be modified. Returns: List of new messages. r_N)rIr@rcs rY new_messagesStreamedRunResult.new_messagesus(  7s37B%B0B%*B!+"B% B#B%!B%#B%cURbURR$URbURR$[S5e))Return the current state of the response.rY)rFrnrBr\r_s rYrnStreamedRunResult.responsesL    '##,, ,  " " .((11 1HI IrXcURbURR$URbURR$g)rN)rFrrBr_s rYrStreamedRunResult.metadatasC    '##,, ,  " " .((11 1rXcURbURR$URbURR$[S5e)rrY)rFr^rBr\r_s rYr^StreamedRunResult.usage sL    '##)) )  " " .((.. .HI IrXcURbURR$URbURR$[S5e)rrY)rFrrBr\r_s rYrStreamedRunResult.timestampsL    '##-- -  " " .((22 2HI IrXcURbURR$URbURR$[S5e)rrY)rFrrBr\r_s rYrStreamedRunResult.run_id$sL    '##** *  " " .((// /HI IrXcURbURR$URbURR$[S5e)rrY)rFrrBr\r_s rYr!StreamedRunResult.conversation_id.sL    '##33 3  " " .((88 8HI IrXrgc# URbURR$URb!URRXS9IShvN $[ S5eN7f)rNrgrY)rFrVrBrlr\r`rrhs rYrl*StreamedRunResult.validate_response_output8s`    '##** *  " " ...GGGmm mHI InsA A!AA!cUR(a6URRUlURRUlURR U5 g)zYAppend a model response to the message history with the correct run and conversation IDs.N)rBrrr>r)r`rs rY_record_response"StreamedRunResult._record_responseCsF  !2299GN&*&;&;&K&KG # !!'*rXc# SSKJn UR(agSUlU"5UlUbUR U5 UR bUR 5IShvN ggN7f)Nr)current_otel_traceparentT)_instrumentationrrGrRrrD)r`rrs rYrs#StreamedRunResult._marked_completedJsa>    ":"<    ! !' *    (##% % % ) %sA A+"A)#A+c# URbWURR5IShvN UR(d#SUlURUR5 gggN:7f)aCancel local stream consumption and request provider shutdown. Whether this stops remote generation or closes the underlying transport depends on the provider SDK. The interrupted response state is recorded in the message history so that `all_messages()` includes it. This stops only the current model response; the run continues. To end the whole run, use [`AgentRun.cancel()`][pydantic_ai.run.AgentRun.cancel] or [`RunContext.cancel()`][pydantic_ai.tools.RunContext.cancel]. NT)rBrrGrrnr_s rYrStreamedRunResult.cancelVs]  ,''..0 0 0###' %%dmm4$ - 0s+A*A(;A*cJURbURR$g)rF)rBrr_s rYrStreamedRunResult.cancelledks%  ,((22 2rX)r>r@rDrFrBrRrG) rIr=rJr?rirArKrCrr&)rIr=rJr?rPAgentRunResult[OutputDataT]rr&)NNN) rIr=rJr?rirArKrCrPrErr&)rrr` str | Nonerr=r`rrbytesr r#r"r.r*r)r,r-r(r/)rr+rr&rS)rz_messages.ModelResponse | Nonerr&r%r')#r2r3r4r5__doc__r6rBrDrFrrGrrLr9r]rIrhrmrprprrirrnrr^rrrrlrrsrrr:rWrXrYr<r<sXP//DHAH9=L6=6:K3:e%8K82E  :   2 0   HL<@9=  2  E  :  7    *'J'JRHL""MQ HLs MQ BEJ227TWJ<DGJ> JJJ J JJJJJJJJO J. JBF J  J+ &5*rXr<cz\rSrSr%SrS\S'S SjrS!SjrS"SjrSS .S#S jjr SS .S$S jjr SS .S#S jjr SS .S$S jjr SS.S%Sjjr SSS.S&SjjrSS.S'SjjrS(Sjr\S)Sj5r\S*Sj5r\S+Sj5r\S,Sj5r\S,Sj5r\S-Sj5rSS.S.Sjjr\S/Sj5rSrg)0r6ita8Synchronous wrapper for [`StreamedRunResult`][pydantic_ai.result.StreamedRunResult] that only exposes sync methods. All of the run's async work happens on the caller's event loop. Context-manager and iterator lifecycles remain in stable tasks, so cancel scopes entered and exited by the agent graph never straddle tasks and OpenTelemetry spans stay correctly nested. The wrapper must be used and closed on the thread where it was created. This is a synchronous context manager; the underlying stream is cleaned up on exit: ```python from pydantic_ai import Agent agent = Agent('openai:gpt-5.2') def main(): with agent.run_stream_sync('What is the capital of the UK?') as response: print(response.get_output()) #> The capital of the UK is London. ``` Using it without a `with` block also works for backwards compatibility. Garbage collection requests best-effort cleanup on the owner loop, but it cannot drive a stopped owner loop from another thread or while another loop is running. A `with` block should be used whenever deterministic cleanup matters. z*StreamedRunResult[AgentDepsT, OutputDataT]_streamed_run_resultc[U[5(a [S5e[USS9UlURR Ulg)Nz`StreamedRunResultSync` now takes the `run_stream()` context manager rather than an already-entered `StreamedRunResult`; use `agent.run_stream_sync(...)` to construct it.z `run_stream`)async_alternative)rr< TypeErrorr*_bridgerr)r` run_stream_cms rYrLStreamedRunResultSync.__init__sG m%6 7 7i ( X $(LL$7$7!rXcU$rSrWr_s rY __enter__StreamedRunResultSync.__enter__s rXc>URRXU45 grS)rshutdown)r`exc_typeexc_valexc_tbs rY__exit__StreamedRunResultSync.__exit__s x&9:rXNr_c4URRUS9$)aReturn the history of messages. Args: output_tool_return_content: The return content of the tool call to set in the last message. This provides a convenient way to modify the content of the output tool call if you want to continue the conversation and want to set the response to the output tool call. If `None`, the last message will not be modified. Returns: List of messages. r_)rrIrcs rYrI"StreamedRunResultSync.all_messagess((55Qk5llrXc4URRUS9$)aReturn all messages from [`all_messages`][pydantic_ai.result.StreamedRunResultSync.all_messages] as JSON bytes. Args: output_tool_return_content: The return content of the tool call to set in the last message. This provides a convenient way to modify the content of the output tool call if you want to continue the conversation and want to set the response to the output tool call. If `None`, the last message will not be modified. Returns: JSON bytes representing the messages. r_)rrhrcs rYrh'StreamedRunResultSync.all_messages_json((::Vp:qqrXc4URRUS9$)rlr_)rrmrcs rYrm"StreamedRunResultSync.new_messagess((55Qk5llrXc4URRUS9$)aReturn new messages from [`new_messages`][pydantic_ai.result.StreamedRunResultSync.new_messages] as JSON bytes. Args: output_tool_return_content: The return content of the tool call to set in the last message. This provides a convenient way to modify the content of the output tool call if you want to continue the conversation and want to set the response to the output tool call. If `None`, the last message will not be modified. Returns: JSON bytes representing the new messages. r_)rrprcs rYrp'StreamedRunResultSync.new_messages_jsonrrXrcrdc^^^URmURRUU4Sj5$)a Stream the output as an iterable. The pydantic validator for structured data will be called in [partial mode](https://docs.pydantic.dev/dev/concepts/experimental/#partial-validation) on each iteration. Args: debounce_by: by how much (if at all) to debounce/group the output chunks by. `None` means no debouncing. Debouncing is particularly important for long structured outputs to reduce the overhead of performing validation as each token is received. Returns: An iterable of the response data. c">TRTS9$Nrd)rprer]srYrZ5StreamedRunResultSync.stream_output..s0D0DQ\0D0]rXrr stream_syncr`rer]s `@rYrp#StreamedRunResultSync.stream_outputs&**||''(]^^rXFr}cb^^^URmURRUUU4Sj5$)uStream the text result as an iterable. !!! note [`TextOutput`][pydantic_ai.output.TextOutput] functions are not applied — use [`stream_output()`][pydantic_ai.result.StreamedRunResultSync.stream_output] instead. Result validators will NOT be called on the text result if `delta=True`. Args: delta: if `True`, yield each chunk of text as it is received, if `False` (default), yield the full text up to the current point. debounce_by: by how much (if at all) to debounce/group the response chunks by. `None` means no debouncing. Debouncing is particularly important for long structured responses to reduce the overhead of performing validation as each token is received. c$>TRTTS9$)Nr})r)rer~r]srYrZ3StreamedRunResultSync.stream_text..s0B0B\g0B0hrXr)r`r~rer]s ``@rYr!StreamedRunResultSync.stream_texts&**||''(hiirXc^^^URmURRUU4Sj5$)a6Stream the response as an iterable of `ModelResponse` snapshots. Each yielded `ModelResponse` is the current state of the response: `response.state` is `'incomplete'` while streaming is in flight and `'complete'` on the final yield. Args: debounce_by: by how much (if at all) to debounce/group the response chunks by. `None` means no debouncing. Debouncing is particularly important for long structured responses to reduce the overhead of performing validation as each token is received. Returns: An iterable of `ModelResponse` snapshots. c">TRTS9$r)rirsrYrZ7StreamedRunResultSync.stream_response..s0F0FS^0F0_rXrrs `@rYri%StreamedRunResultSync.stream_responses&**||''(_``rXc`URRURR5$)r{)rcallrrr_s rYr StreamedRunResultSync.get_outputs#||  !:!:!E!EFFrXc.URR$)r~)rrnr_s rYrnStreamedRunResultSync.response((111rXc.URR$)r)rr^r_s rYr^StreamedRunResultSync.usages((...rXc.URR$r)rrr_s rYrStreamedRunResultSync.timestamp(rrXc.URR$r)rrr_s rYrStreamedRunResultSync.run_id-s((///rXc.URR$r)rrr_s rYr%StreamedRunResultSync.conversation_id2s((888rXc.URR$r)rrr_s rYrStreamedRunResultSync.metadata7rrXrgcJ^^^TRRUUU4Sj5$)rc8>TRRTTS9$)Nrg)rrl)rhrr`srYrZ@StreamedRunResultSync.validate_response_output..?sD--FFw^kFlrX)rrrs```rYrl.StreamedRunResultSync.validate_response_output<s||  l  rXc.URR$)aWhether the stream has all been received. This is set to `True` when one of [`stream_output`][pydantic_ai.result.StreamedRunResultSync.stream_output], [`stream_text`][pydantic_ai.result.StreamedRunResultSync.stream_text], [`stream_response`][pydantic_ai.result.StreamedRunResultSync.stream_response] or [`get_output`][pydantic_ai.result.StreamedRunResultSync.get_output] completes. )rrGr_s rYrG!StreamedRunResultSync.is_completeBs((444rX)rr)rzGAbstractAsyncContextManager[StreamedRunResult[AgentDepsT, OutputDataT]]rr&)rr)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonerr&rr)rer!rzIterator[OutputDataT])r~r$rer!rz Iterator[str])rer!rz!Iterator[_messages.ModelResponse]r.r*r,r-r(r)r/r')r2r3r4r5rr6rLrrrIrhrmrprprrirr9rnr^rrrrrlrGr:rWrXrYr6r6ts;2ED 8;,;&;% ;  ;HL mMQ rHLm MQ rAa"G22//33009922ch  5 5rXr6)rGc^\rSrSr%SrS\S'SrS\S'SrS\S'\Rr S r g) FinalResultiOzNMarker class storing the final output of an agent run and associated metadata.r-rVNrr tool_call_idrW) r2r3r4r5rr6rrrdataclasses_no_defaults_repr__repr__r:rWrXrYrrOs3X   Iz b#L*#w22HrXrcl^^^Tb$TR5(aUUU4SjnU"5$[T5$)Nc># TShvN nTRT"55 TRTRR5 U7v MKNF g7frS) check_tokenscheck_per_request_input_tokensr^ input_tokens)item get_usagelimitsris rY_usage_checking_iteratorE_get_usage_checking_stream_response.._usage_checking_iteratorfsF- d##IK055o6K6K6X6XY  os&AAAAAAAA)has_token_limitsr)rirrrs``` rYrr_s4 f5577  ())_%%rXc/n/nUHinURUR5nUcM#URS:XaURU5 MFURS:XdMXURU5 Mk U(dU(dg[ X2S9$)zBGet the deferred tool requests from the model response tool calls.N unapprovedexternal)calls approvals) get_tool_defrkindrr0)r tool_managerrrrtool_defs rYrrqs{/1I*,E ,,Y-@-@A  }} ,  +*, Y'    e AArX)rir;rrArzCallable[[], RunUsage]rr1)rz Iterable[_messages.ToolCallPart]rrCrzDeferredToolRequests | None)P __future__r _annotationscollections.abcrrrrrr contextlibr r copyr dataclassesr rrrdecimalrtypesrtypingrrrrrrUpydanticrtyping_extensionsrrrrrrr _genai_pricesr_outputr r!r"r#r$r%r& _run_contextr'r(r) _sync_streamr*r+r,rVr-r.rr/toolsr0r^r1r2capabilities.abstractr3r[r5__all__r9r<r6rrrrWrXrYr s]2bb<11>> $"??,HG*@&'(9#  4v'*k12vvr  C K 78CCL X5GJ $;<X5v  3'+& 3 3&,& &&&- &$B0B@WB BrX