.hY$ddlmZddlZddlZddlmZddlmZmZddl m Z m Z m Z ddl mZddlmZdd lmZdd lmZdd lmZmZdd lmZmZdd lmZmZmZmZddl m Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(m)Z)e r ddlmZdd lmZedZ*eGddej+Z,eGdde,Z-eGdde,Z.dS)) annotationsN) AsyncIterator) dataclassfield) TYPE_CHECKINGAnycast)TypeVar)QueueCompleteSentinel)Agent)AgentOutputSchemaBase)InputGuardrailTripwireTriggeredMaxTurnsExceeded)InputGuardrailResultOutputGuardrailResult) ItemHelpers ModelResponseRunItemTResponseInputItem)logger)RunContextWrapper) StreamEvent)Trace)pretty_print_result!pretty_print_run_result_streamingTceZdZUded< ded< ded< ded< d ed < d ed < d ed< eejddZdd dZd!dZ ed"dZ dS)# RunResultBasezstr | list[TResponseInputItem]inputz list[RunItem] new_itemszlist[ModelResponse] raw_responsesr final_outputzlist[InputGuardrailResult]input_guardrail_resultszlist[OutputGuardrailResult]output_guardrail_resultszRunContextWrapper[Any]context_wrapperreturn Agent[Any]cdS)The last agent that was run.Nselfs J/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/agents/result.py last_agentzRunResultBase.last_agent9sFclstype[T]raise_if_incorrect_typeboolrc|r,t|j|std|jt t |jS)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 ) isinstancer# TypeError__name__r r)r-r1r3s r.final_output_aszRunResultBase.final_output_as>sN # K:d6G+M+M KI3<IIJJ JAt()))r0list[TResponseInputItem]c`tj|j}d|jD}||zS)zVCreates a new input list, merging the original input with all the new items generated.c6g|]}|Sr+) to_input_item).0items r. z/RunResultBase.to_input_list..Ss$EEEdT''))EEEr0)rinput_to_new_input_listr r!)r-original_itemsr!s r. to_input_listzRunResultBase.to_input_listPs63>3VW[Wa3b3bEEdnEEE  ))r0 str | Nonec8|jsdS|jdjS)zEConvenience method to get the response ID of the last model response.N)r" response_idr,s r.last_response_idzRunResultBase.last_response_idWs%! 4!"%11r0Nr'r()F)r1r2r3r4r'r)r'r:)r'rD) r8 __module__ __qualname____annotations__propertyabcabstractmethodr/r9rCrHr+r0r.rrs))))'&&&L'777739999>++++0 +++X+*****$****222X222r0rc:eZdZUded<eddZd dZdS) RunResultr( _last_agentr'c|jS)r*)rRr,s r.r/zRunResult.last_agentds r0strc t|SN)rr,s r.__str__zRunResult.__str__is"4(((r0NrIr'rT)r8rJrKrLrMr/rWr+r0r.rQrQ`sT    X ))))))r0rQceZdZUdZded< ded< ded< ded< ed Zd ed <ed Zd ed<d Zded< ee j d Z ded<ee j d Z ded<edd Z ded<edd Zded<edd Zded<edd Zded<ed(dZd)d!Zd*d#Zd$Zd%Zd+d'ZdS),RunResultStreamingaJThe 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_agentint current_turn max_turnsrr#F)reprzAgentOutputSchemaBase | None_current_agent_output_schemaz Trace | Nonetracer4 is_complete)default_factoryr_z2asyncio.Queue[StreamEvent | QueueCompleteSentinel] _event_queuez#asyncio.Queue[InputGuardrailResult]_input_guardrail_queueN)defaultr_zasyncio.Task[Any] | None_run_impl_task_input_guardrails_task_output_guardrails_taskzException | None_stored_exceptionr'c|jS)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. )r[r,s r.r/zRunResultStreaming.last_agents !!r0Nonecl|d|_|js2|j|j2|js4|j|j2dSdS)zaCancels the streaming run, stopping all background tasks and marking the run as complete.TN)_cleanup_tasksrbrdempty get_nowaitrer,s r.cancelzRunResultStreaming.cancels #))++ +   ( ( * * *#))++ +-3355 5  ' 2 2 4 4 4-3355 5 5 5 5 5r0AsyncIterator[StreamEvent]c0K ||jrtjdd|_n|jr|jrn |jd{V}n#tj $rYnfwxYwt|tr.|j |n|WV|j | |jr|jdS)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. Tz Breaking due to stored exceptionN) _check_errorsrjrdebugrbrdrogetasyncioCancelledErrorr6r task_donern)r-r?s r. stream_eventsz RunResultStreaming.stream_eventssN *    %  ?@@@#'  D$5$;$;$=$=  !.2244444444)    $ 566 !++---""$$$JJJJ   ' ' ) ) )- *0   ! )( ( ) )sA==BBcP|j|jkrtd|jd|_|jsR|j}|jjrt||_|jR|j rP|j r7|j }|rt|tr||_|jrP|j r7|j }|rt|tr||_|jrR|j r;|j }|r"t|tr||_dSdSdSdSdS)Nz Max turns (z ) exceeded)r]r^rrjrerorpoutputtripwire_triggeredrrgdone exceptionr6 Exceptionrhri)r-guardrail_resultexcs r.rtz RunResultStreaming._check_errorss  t~ - -%56^DN6^6^6^%_%_D "-3355 [#:EEGG &9 [)HIY)Z)Z&-3355 [   -4#6#;#;#=#= -%//11C -z#y11 -),&  & -4+F+K+K+M+M --7799C -z#y11 -),&  ' -D,H,M,M,O,O -.88::C -z#y11 -),&&& - - - - - - - -r0cd|jr2|js|j|jr2|js|j|jr4|js|jdSdSdSrV)rgr~rqrhrir,s r.rnz!RunResultStreaming._cleanup_taskss   )t':'?'?'A'A )   & & ( ( (  & 1t/J/O/O/Q/Q 1  ' . . 0 0 0  ' 20L0Q0Q0S0S 2  ( / / 1 1 1 1 1 2 2 2 2r0rTc t|SrV)rr,s r.rWzRunResultStreaming.__str__s0666r0rI)r'rl)r'rrrX)r8rJrK__doc__rLrr`rarbrwQueuerdrergrhrirjrMr/rqrzrtrnrWr+r0r.rZrZms,"NNN<[AFEARARAR RRRR%U+++E++++K1HMu EHHHLCH% ECCC 05uT/N/N/NNNNNN7rs_"""""" ))))))((((((((++++++++++%%%%%%,,,,,,//////IIIIIIIIBBBBBBBBJJJJJJJJJJJJ******&&&&&&VVVVVVVV000000 GCLL >2>2>2>2>2CG>2>2 >2B  ) ) ) ) ) ) )  ) H7H7H7H7H7H7H7 H7H7H7r0