Ë
    S^(hL  ã                   ó€   — d dl mZ ddlmZmZmZ  ej                  e«      Zdde	de
fd„Zddede
fd„Z G d	„ d
«      Zy)é   )Úloggingé   )Ú
AgentAudioÚ
AgentImageÚ	AgentTextÚstep_logÚ	test_modec              #   óä  K  — 	 ddl m} | j                  d«      r |d| d   ¬«      –— | j                  d	«      r<| d	   d
   dk(  }| d	   d   }|rd|› d�} |ddd| d	   d
   › �it	        |«      ¬«      –— | j                  d«      r |dd| d   › d�¬«      –— | j                  d«      r |dt	        | d   «      ddi¬«      –— y y # t        $ r |r G d„ d«      }nt        d«      ‚Y Œâw xY w­w)Né    ©ÚChatMessagec                   ó   — e Zd Zdd„Zy)ú!pull_message.<locals>.ChatMessageNc                 ó.   — || _         || _        || _        y ©N©ÚroleÚcontentÚmetadata©Úselfr   r   r   s       ú\/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/transformers/agents/monitoring.pyÚ__init__z*pull_message.<locals>.ChatMessage.__init__   ó   € Ø $�D”IØ#*�D”LØ$,�D•Mó    r   ©Ú__name__Ú
__module__Ú__qualname__r   © r   r   r   r      ó   „ ô-r   r   ú<Gradio should be installed in order to launch a gradio demo.Ú	rationaleÚ	assistant©r   r   Ú	tool_callÚ	tool_namezcode interpreterÚtool_argumentsz```py
ú
```Útitleu   ðŸ› ï¸� Used tool )r   r   r   Úobservationz```
Úerroru
   ðŸ’¥ Errorr   )Úgradior   ÚImportErrorÚgetÚstr)r   r	   r   Ú	used_coder   s        r   Úpull_messager2      s6  è ø€ ð^Ý&ð ‡|�|�KÔ Ù˜{°H¸[Ñ4IÔJÒJØ‡|�|�KÔ Ø˜[Ñ)¨+Ñ6Ð:LÑLˆ	Ø˜;Ñ'Ð(8Ñ9ˆÙØ ˜y¨Ð.ˆGÙØØÐ!3°H¸[Ñ4IÈ+Ñ4VÐ3WÐXÐYÜ˜“Lô
ò 	
ð
 ‡|�|�MÔ"Ù˜{°e¸HÀ]Ñ<SÐ;TÐTYÐ4ZÔ[Ò[Ø‡|�|�GÔÙØÜ˜ Ñ)Ó*Ø˜|Ð,ô
ó 	
ð øô3 ò 	^Ù÷-ò -ô Ð\Ó]Ð]ñ-ð	^üs(   ‚C0„C	 ŠB?C0Ã	!C-Ã*C0Ã,C-Ã-C0Útaskc              +   ó0  K  — 	 ddl m}  | j                  |fddi|¤ŽD ])  }t	        |t
        «      sŒt        ||¬«      D ]  }|–— Œ Œ+ }t	        |t        «      r |d	d
|j                  «       › d�¬«      –— yt	        |t        «      r |d	|j                  «       ddœ¬«      –— yt	        |t        «      r |d	|j                  «       ddœ¬«      –— y |d	t        |«      ¬«      –— y# t        $ r |r G d„ d«      }nt        d«      ‚Y �Œw xY w­w)zaRuns an agent with the given task and streams the messages from the agent as gradio ChatMessages.r   r   c                   ó   — e Zd Zdd„Zy)ú%stream_to_gradio.<locals>.ChatMessageNc                 ó.   — || _         || _        || _        y r   r   r   s       r   r   z.stream_to_gradio.<locals>.ChatMessage.__init__E   r   r   r   r   r    r   r   r   r6   D   r!   r   r   r"   ÚstreamT)r	   r$   z**Final answer:**
```
r)   r%   z	image/png)ÚpathÚ	mime_typez	audio/wavN)r-   r   r.   ÚrunÚ
isinstanceÚdictr2   r   Ú	to_stringr   r   r0   )Úagentr3   r	   Úkwargsr   r   ÚmessageÚfinal_answers           r   Ústream_to_gradiorC   <   s+  è ø€ ð^Ý&ð �E—I‘I˜dÑ:¨4Ð:°6Ñ:ò ˆÜ�h¤Õ%Ü'¨¸IÔFò �Ø“ñðð
 €Lä�,¤	Ô*Ù˜{Ð6NÈ|×OeÑOeÓOgÐNhÐhmÐ4nÔoÓoÜ	�L¤*Ô	-ÙØØ)×3Ñ3Ó5ÀKÑPô
ó 	
ô 
�L¤*Ô	-ÙØØ)×3Ñ3Ó5ÀKÑPô
ó 	
ñ
 ˜{´C¸Ó4EÔFÓFøô? ò 	^Ù÷-ò -ô Ð\Ó]Ð]ò-ð	^üs-   ‚D„C. Š(D³B;DÃ.!DÄDÄDÄDc                   ó   — e Zd Zd„ Zd„ Zy)ÚMonitorc                 ór   — g | _         || _        t        | j                  dd«      dk7  rd| _        d| _        y y )NÚlast_input_token_countz	Not foundr   )Ústep_durationsÚtracked_llm_engineÚgetattrÚtotal_input_token_countÚtotal_output_token_count)r   rI   s     r   r   zMonitor.__init__d   sA   € Ø ˆÔØ"4ˆÔÜ�4×*Ñ*Ð,DÀkÓRÐVaÒaØ+,ˆDÔ(Ø,-ˆDÕ)ð br   c                 ó,  — |d   }| j                   j                  |«       t        j                  dt	        | j                   «      › d�«       t        j                  d|d›d�«       t        | j                  dd «      �—| xj                  | j                  j                  z  c_        | xj                  | j                  j                  z  c_	        t        j                  d| j                  › �«       t        j                  d	| j                  › �«       y y )
NÚstep_durationzStep ú:z- Time taken: z.2fz' seconds (valid only if step succeeded)rG   z- Input tokens: z- Output tokens: )rH   ÚappendÚloggerÚinfoÚlenrJ   rI   rK   rG   rL   Úlast_output_token_count)r   r   rN   s      r   Úupdate_metricszMonitor.update_metricsk   sæ   € Ø  Ñ1ˆØ×Ñ×"Ñ" =Ô1Ü�‰�eœC × 3Ñ 3Ó4Ð5°QÐ7Ô8Ü�‰�n ]°3Ð$7Ð7^Ð_Ô`ä�4×*Ñ*Ð,DÀdÓKÐWØ×(Ò(¨D×,CÑ,C×,ZÑ,ZÑZÕ(Ø×)Ò)¨T×-DÑ-D×-\Ñ-\Ñ\Õ)Ü�K‰KÐ*¨4×+GÑ+GÐ*HÐIÔJÜ�K‰KÐ+¨D×,IÑ,IÐ+JÐKÕLð	 Xr   N)r   r   r   r   rU   r    r   r   rE   rE   c   s   „ ò.ó
Mr   rE   N)T)F)Úutilsr   Úagent_typesr   r   r   Ú
get_loggerr   rQ   r=   Úboolr2   r0   rC   rE   r    r   r   ú<module>rZ      s[   ðõ" ß :Ñ :ð 
ˆ×	Ñ	˜HÓ	%€ñ!
˜4ð !
¨Dó !
ñH$G #ð $G°$ó $G÷NMò Mr   