Cj/SSKJr SSKrSSKrSSKrSSKrSSKJr SSKJ r J r J r SSK J r JrJrJrJr SSKJr SSKJr SS KJr SS KJr SS KJrJrJrJr SS KJ r J!r! SS K"J#r#J$r$J%r%J&r&J'r' SSK(J(r( SSK)J*r* SSK+J,r, SSK-J.r.J/r/J0r0 SSK1J2r2 SSK3J4r4 SSK5J6r6J7r7 SSK8J9r9 SSK:J;r; SSKr> \ (aSSKJ?r?J@r@ SSKAJBrB \"S5rC\ "SS9"SS55rDSSSS .S+S"jjrE\S#rFS,S$jrGS-S%jrH\ "S&S!\R55rJ\ "S'S(\J55rK\ "S)S*\J55rLg).) annotationsN) AsyncIterator)InitVar dataclassfield) TYPE_CHECKINGAnyLiteralTypeVarcast)GetCoreSchemaHandler) core_schema)Agent)AgentOutputSchemaBase)AgentsExceptionInputGuardrailTripwireTriggeredMaxTurnsExceededRunErrorDetails)InputGuardrailResultOutputGuardrailResult) ItemHelpers ModelResponseRunItemToolApprovalItemTResponseInputItem)logger)RunContextWrapper)run_items_to_input_items)NextStepInterruptionProcessedResponseQueueCompleteSentinel)RunState) StreamEvent)ToolInputGuardrailResultToolOutputGuardrailResult)Trace) TraceState)pretty_print_result!pretty_print_run_result_streaming) AwaitableCallable)BaseSandboxSessionTT)frozenc<\rSrSr%SrS\S'S\S'S\S'Srg) AgentToolInvocation8z8Immutable metadata about a nested agent-tool invocation.str tool_name tool_call_idtool_argumentsN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__r7_/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/agents/result.pyr1r18sBN45;r?r1F)conversation_idprevious_response_idauto_previous_response_id RunResultBasec4URUl[USS5n [U [5(a[ U 5UlOUR Ul[ UR 5UlURUl URUl URUl URUlUR UlX0lX lX@lUR+U5 X`lXplXl[USS5n [U [25(aU R4UlO[USS5Ul[USS5Ul[ [US/55n U (a[9U S9Ul[USS5n U c![<R>"[US S55n U (a[@RB"U 5OSUl"[US S5n [U [F5(a[@RB"U 5Ul$U$SUl$U$) z8Populate a RunState with common fields from a RunResult._model_input_itemsN_state_generated_prompt_cache_key_reasoning_item_id_policy interruptions)rJ _trace_statetrace_sandbox_resume_state)% last_agent_current_agentgetattr isinstancelist_generated_items new_items_session_items raw_responses_model_responsesinput_guardrail_results_input_guardrail_resultsoutput_guardrail_results_output_guardrail_resultstool_input_guardrail_results_tool_input_guardrail_resultstool_output_guardrail_results_tool_output_guardrail_results_last_processed_response _current_turn"_current_turn_persisted_item_countset_tool_use_tracker_snapshot_conversation_id_previous_response_id_auto_previous_response_idr#rHrIr _current_stepr( from_tracecopydeepcopyrKdict_sandbox)stateresult current_turnlast_processed_response!current_turn_persisted_item_counttool_use_tracker_snapshotrArBrCmodel_input_items source_staterJ trace_statesandbox_resume_states r@_populate_state_from_resultrwFs",,E(M2O&.$7K ++GFGT,JK 7B{3E"6+BDI&--';< L Lr?) preserve_all normalizedc[URU5nUS:XaU$US:wa[SU35e[USS5(dU$[USS5n[ U[ 5(dU$[XB5$)aReturn input items for the requested result view. ``preserve_all`` keeps the full converted history from ``new_items``. ``normalized`` returns the canonical continuation input when handoff filtering rewrote model history, otherwise it falls back to the same converted history. rxryz Unsupported to_input_list mode: _replay_from_model_input_itemsFrFN)rrT ValueErrorrPrQrR)rnmodereasoning_item_id_policy session_itemsrss r@_input_items_for_resultrs-V-=-=?WXM ~ |;D6BCC 6;U C C(G$$I' **,r?cDURSS9 g![a gf=f)NFr)r Exceptionrs r@__del__RunResultBase.__del__s,    %  8   s  cg)zDRelease stored agent reference specific to the concrete result type.Nr7rs r@r+RunResultBase._release_last_agent_referencerr?cU(a3[URU5(d[SUR35e[ [ UR5$)aA convenience method to cast the final output to a specific type. By default, the cast is only for the typechecker. If you set `raise_if_incorrect_type` to True, we'll raise a TypeError if the final output is not of the given type. Args: cls: The type to cast the final output to. raise_if_incorrect_type: If True, we'll raise a TypeError if the final output is not of the given type. Returns: The final output casted to the given type. zFinal output is not of type )rQr TypeErrorr8r r.)rrraise_if_incorrect_types r@final_output_asRunResultBase.final_output_as sC #:d6G6G+M+M:3<<.IJ JAt(())r?rx)r}cz[R"UR5n[USS5n[ UUUS9nX$-$)a4Create an input-item view of this run. ``mode="preserve_all"`` keeps the historical behavior of converting ``new_items`` into a full plain-item history. ``mode="normalized"`` prefers the canonical continuation input when handoff filtering rewrote model history, while remaining identical for ordinary runs. rIN)r}r~)rinput_to_new_input_listrrPr)rr}original_itemsr~ replay_itemss r@ to_input_listRunResultBase.to_input_listsI4?3V3VW[WaWa3b#*41Ld#S . %= ,,r?cSSKJn [URU5(dg[ URR URR URRS9$)zkImmutable metadata for results produced by `Agent.as_tool()`. Returns `None` for ordinary top-level runs. r) ToolContextN)r4r5r6) tool_contextrrQrr1r4r5r6)rrs r@agent_tool_invocation#RunResultBase.agent_tool_invocation2sW .$.. <<"**44--:://>>  r?cXUR(dgURSR$)zEConvenience method to get the response ID of the last model response.N)rV response_idrs r@last_response_idRunResultBase.last_response_idCs'!!!!"%111r?r7)rr rr returnzcore_schema.CoreSchemar Agent[Any])rrrNonerr)F)rztype[T]rrrr.)r}ToInputListModerlist[TResponseInputItem])rzAgentToolInvocation | None)rr)r8r9r:r;r=rrKr{rMrrrH classmethodrpropertyabcabstractmethodrNrrrrrrrr>r7r?r@rDrDs ))'&L'77399>"@@N#BBO++0&+Du5&QL#Q<+0UQV+W"DW 7r7r?r@rrLsI@E  AO= :?tRW9X6X\79r'SC\SD'\"SS S S>9r(SE\SF'\"S S S S>9r)S\SG'SYSHjr*\+SZSIj5r,S[SJjr-S[SKjr.S[SLjr/\+S\SMj5r0S]S^SNjjr1S_SOjr2S`SPjr3SQr4SRr5SaSSjr6SbSTjr7S[SUjr8S[SVjr9ScSWjr:SXr;g)dRunResultStreamingia6The result of an agent run in streaming mode. You can use the `stream_events` method to receive semantic events as they are generated. The streaming method will raise: - A MaxTurnsExceeded exception if the agent exceeds the max_turns limit. - A GuardrailTripwireTriggered exception if a guardrail is tripped. r current_agentrrorr rF)rzAgentOutputSchemaBase | None_current_agent_output_schemaz Trace | NonerLr is_completeNrr_current_agent_refrrrFz2asyncio.Queue[StreamEvent | QueueCompleteSentinel] _event_queuez#asyncio.Queue[InputGuardrailResult]_input_guardrail_queuerasyncio.Task[Any] | None run_loop_task_input_guardrails_taskzInputGuardrailResult | None!_triggered_input_guardrail_result_output_guardrails_taskzException | None_stored_exceptionnonez*Literal['none', 'immediate', 'after_turn'] _cancel_moderr`rrrJ_waiting_on_event_queuerrb_stream_input_persistedzlist[TResponseInputItem] | None_original_input_for_persistence_max_turns_handledrrrrrGrrdrerfrrrIz!InitVar[asyncio.Task[Any] | None]_run_impl_taskz$Callable[[], Awaitable[None]] | None_sandbox_cleanupzasyncio.Task[None] | None_sandbox_cleanup_task$_sandbox_cleanup_callback_registeredc[R"UR5UlURcUR UlUR c UbXlgggr)rrrrrrr )rrs r@r RunResultStreaming.__post_init__sQ")++d.@.@"A    '#'::D    %.*D!/ +E %r?c[SURRS55nUbU$UR(aUR5nUbU$[ S5e)zThe last agent that was run. Updates as the agent run progresses, so the true last agent is only available after the agent run is complete. rrr)r rrrrrs r@rNRunResultStreaming.last_agent%sY ($--*;*;O*LM  L  " "++-E  LMMr?c[SURRS55nUcg[R"U5UlSURS'g)Nrr)r rrrrrrs r@r0RunResultStreaming._release_last_agent_reference3sE($--*;*;O*LM = ")++e"4)- o&r?c^# URmTcgURnUc)SU4Sjjn[R"U"55nXlUIShvN gN7f)Nc># T"5IShvN gN![a!n[R"SU5 SnAgSnAff=f7f)Nz;Failed to clean up sandbox resources after streamed run: %s)rrwarning)errorsandbox_cleanups r@ _cleanup_once>RunResultStreaming._run_sandbox_cleanup.._cleanup_onceCs=)+++ NNUW\s3A A A=AAAr)rrasyncio create_task)rtaskr%r$s @r@_run_sandbox_cleanup'RunResultStreaming._run_sandbox_cleanup;sP//  " )) < &&}7D)- & sAAAAc^^TRbTRbTR(agTRmSTlTRU4Sj5 SUU4Sjjn[R "U"55Tlg)NTcL>[R"TR55$r)r'r(r*)_taskrs r@IRunResultStreaming.ensure_sandbox_cleanup_on_completion..[s'--d.G.G.IJr?c ># TIShvN nTR 5IShvN U$N![Ra' TR5(dTR5 e[a TR 5IShvN ef=fNi7fr)r'CancelledErrordonecancelrr*)rn original_taskrs r@_await_run_and_cleanupWRunResultStreaming.ensure_sandbox_cleanup_on_completion.._await_run_and_cleanup^s ,,++- - -M-)) $))++!((* //111  .s<B+)+BB B+AB BB  B)rr )rr radd_done_callbackr'r()rr6r5s` @r@$ensure_sandbox_cleanup_on_completion7RunResultStreaming.ensure_sandbox_cleanup_on_completionPsn  ! ! )!!)88 ** 481'' J   %001G1IJr?cURnUb*UR5(aUR5(agUR5$)a}The exception raised by the background run loop, if any. When the run loop fails before producing stream events (for example during early sandbox initialisation), the exception may not be re-raised through :meth:`stream_events`. This property gives callers a reliable way to check for silent failures after consuming the stream: .. code-block:: python result = Runner.run_streamed(agent, "hello") async for event in result.stream_events(): pass if result.run_loop_exception: raise result.run_loop_exception Returns ``None`` if the run loop completed without error, has not yet finished, or was cancelled. N)r r3 cancelled exceptionrr)s r@run_loop_exception%RunResultStreaming.run_loop_exceptionns:(!! .>~~r?cXlUS:XaUR5 SUlURR 5(d;URR 5 URR 5(dM;UR R[55 UR(dUR5 ggUS:Xagg)aKCancel the streaming run. Args: mode: Cancellation strategy: - "immediate": Stop immediately, cancel all tasks, clear queues (default) - "after_turn": Complete current turn gracefully before stopping * Allows LLM response to finish * Executes pending tool calls * Saves session state properly * Tracks usage accurately * Stops before next turn begins Example: ```python result = Runner.run_streamed(agent, "Task", session=session) async for event in result.stream_events(): if user_interrupted(): result.cancel(mode="after_turn") # Graceful # result.cancel() # Immediate (default) ``` Note: After calling cancel(), you should continue consuming stream_events() to allow the cancellation to complete properly. immediateT after_turnN) r_cleanup_tasksrr empty get_nowaitr put_nowaitr"r_drain_event_queue)rr}s r@r4RunResultStreaming.cancels6! ;     !#D 117799++668117799    ( ()>)@ A//'')0\ !  "r?c# SnUR5 [UR[5nUR(aDU(aURR 5(a[ R"S5 SUlOUR(a URR 5(aOSUl URR5IShvN nSUl [U[5(aNURUR 5IShvN URR#5 UR5 O"U7v URR#5 GMgU(aUR%5 OCURUR&5IShvN UR5 UR%5 U(dUR)5IShvN [R*"S5IShvN UR-5 UR/5 UR(a URegGNi![Ra SnUR5 ef=f!SUl f=fGNcNNN![R*"S5IShvN UR-5 UR/5 f=f!U(aUR%5 ODURUR&5IShvN UR5 UR%5 U(dUR)5IShvN [R*"S5IShvN UR-5 UR/5 f![R*"S5IShvN UR-5 UR/5 f=f=f7f)aStream deltas for new items as they are generated. We're using the types from the OpenAI Responses API, so these are semantic events: each event has a `type` field that describes the type of the event, along with the data for that event. This will raise: - A MaxTurnsExceeded exception if the agent exceeds the max_turns limit. - A GuardrailTripwireTriggered exception if a guardrail is tripped. FTz Breaking due to stored exceptionNr) _check_errorsrQrrrrErdebugrrrr'r2r4r"_await_task_safelyr  task_donerDr r*sleeprH_drain_input_guardrail_queue)rr<should_drain_queued_eventsrs r@ stream_events RunResultStreaming.stream_eventss A 4""$-78N8NP`-a*))2d6G6G6M6M6O6OLL!CD'+D$##(9(9(?(?(A(A937D0!%!2!2!6!6!88D 49D0d$9::11$2M2MNNN%%//1&&( !!++-IL 4'')11$2D2DEEE &&('') 33555mmA&&&'')113  ! !(( ( "g9-- $IKKM 49D0 O(F6'gmmA&&&'')1135 4'')11$2D2DEEE &&('') 33555mmA&&&'')113 mmA&&&'')113sOB1K 8$III":K I?AK /6J%J&>J$J%J)OJAOI(I00I33 I<<K JJOK "J%#&K  O O6N L?N MN  O#M&$&O O $N' %&O  OOc [URURURURUR UR URS9$)zRReturn a `RunErrorDetails` object considering the current attributes of the class.)rrTrVrNrrXrZ)rrrTrVrrrXrZrs r@_create_error_details(RunResultStreaming._create_error_detailssJ**nn,,)) 00$($@$@%)%B%B  r?cURUR:aEUR(d4[SURS35nUR 5UlXlURR5(d|URR5nURR(a&[U5nUR 5UlX0lURR5(dM|UR(aURR5(aURR5(dsURR!5nU(aR[#U[$5(a=[#U[&5(a"UR cUR 5UlX@lUR((aUR(R5(aUR(R5(dsUR(R!5nU(aR[#U[$5(a=[#U[&5(a"UR cUR 5UlXPlUR*(aUR*R5(aUR*R5(dvUR*R!5nU(aT[#U[$5(a>[#U[&5(a"UR cUR 5UlX`lgggggg)Nz Max turns (z ) exceeded)rorrrrUrun_datarr rErFoutputtripwire_triggeredrr r3r<r=rQrrr r)r max_turns_excguardrail_result tripwire_exc run_impl_exc in_guard_exc out_guard_excs r@rK RunResultStreaming._check_errorssd   t~~ -d6M6M,{4>>:J*-UVM%)%?%?%AM "%2 "--3355#::EEG &&99>?OP (,(B(B(D %)5& --3355   $"4"4"9"9";";%%//11#11;;= J|Y$G$G!,@@\EZEZEb040J0J0L --9*  & &4+F+F+K+K+M+M..88::#::DDF J|Y$G$G!,@@\EZEZEb040J0J0L --9*  ' 'D,H,H,M,M,O,O//99;; $ < < F F H  Z y%I%I"=/BB)22:151K1K1M .-:* &J=<-P 'r?cUR(a9URR5(dURR5 UR(a9URR5(dURR5 UR(a;URR5(dURR5 gggr)r r3r4r rrs r@rD!RunResultStreaming._cleanup_tasks=s   d&8&8&=&=&?&?    % % '  & &t/J/J/O/O/Q/Q  ' ' . . 0  ' '0L0L0Q0Q0S0S  ( ( / / 11T 'r?c[U5$r)r*rs r@rRunResultStreaming.__str__Gs 066r?c# U(a"UR5(d UIShvN gggN![Ra g[a gf=f7f)zAwait a task if present, ignoring cancellation and storing exceptions elsewhere. This ensures we do not lose late guardrail exceptions while not surfacing CancelledError to callers of stream_events. N)r3r'r2rr>s r@rM%RunResultStreaming._await_task_safelyJsL    $4))   s=A/-/A/AA AAAAc:URR5(dWURR5 URR5 URR5(dMVgg![R a g[ a gf=f)zARemove any pending items from the event queue and mark them done.N)rrErFrNr' QueueEmptyr|rs r@rH%RunResultStreaming._drain_event_queueZs|##))++ !!,,.!!++-##))++%%   s4A88B BBcURR5(d=URR5 URR5(dM<gg![Ra gf=f)z8Remove any pending items from the input guardrail queue.N)r rErFr'rirs r@rP/RunResultStreaming._drain_input_guardrail_queuefs_--3355 ++668--3355%%  sAA54A5c H[URURb URO UR[ U5UR S9n[ UUURURURURURURURS9 $)a3Create a RunState from this streaming result to resume execution. This is useful when the run was interrupted (e.g., for tool approval). You can approve or reject the tool calls on the returned state, then pass it back to `Runner.run_streamed()` to continue execution. Returns: A RunState that can be used to resume the run. Example: ```python # Run agent until it needs approval result = Runner.run_streamed(agent, "Use the delete_file tool") async for event in result.stream_events(): pass if result.interruptions: # Approve the tool call state = result.to_state() state.approve(result.interruptions[0]) # Resume the run result = Runner.run_streamed(agent, state) async for event in result.stream_events(): pass ``` rr)r#rrrrrrwror`rbrrdrerf)rrms r@rRunResultStreaming.to_statens>((373G3G3S4//Y]YcYc4T:nn  +  **$($A$A.2.U.U&*&E&E 11!%!;!;&*&E&E  r?) rrrrrrrrr )rr rrrr)rzBaseException | None)rB)r}z"Literal['immediate', 'after_turn']rr)rzAsyncIterator[StreamEvent])rrr)r)r rrr)r7r?r@rrs1,"N<[AFEAR ">RU+E<+K1CH  D@ ).d(O OKHM EHLDCH EC? /4Du.MM+M7tRW9X6X\,1$,GM)GF$)%e$DTD./&/%*T)VGK#%DK> %U??=B4V[=\O:\X7: 8=TPU\a7b4b16u5W\1]($]0 N N.*K<  0.`N)`  (;T27 0 r?r)rmrrnrDrorrprrqrrrrrArrBrrCrrr)rnrDr}rr~rrr)rnrDrr)M __future__rrr'rircollections.abcr dataclassesrrrtypingrr r r r pydanticr pydantic_corerrr agent_outputr exceptionsrrrr guardrailrritemsrrrrrr run_contextrrun_internal.itemsrrun_internal.run_stepsr r!r" run_stater#rRr$tool_guardrailsr%r&tracingr'tracing.tracesr(util._pretty_printr)r*r+r,$sandbox.session.base_sandbox_sessionr-r.r1rwrrrABCrDrrr7r?r@rs"  )11==)%/ C*8  &P& 3H CL $ < < <*#''+&+5 5 5 5 6 5 (+ 5 45 5%5 $55p67Q Q QA Q  Q>  Z2CGGZ2 Z2z k) k) k)\ b b  b r?