Ë
    uPêjö  ã                   óÌ   — d dl mZmZ d dlmZmZmZmZ d dlZd dl	m
Z
mZ d dlmZ d dlmZ ddlmZmZmZmZmZmZmZmZmZmZmZmZ d	d
lmZ  G d„ de«      Z G d„ de«      Z y)é    )Ú	CoroutineÚIterable)ÚAnyÚFinalÚLiteralÚ	TypedDictN)ÚAsyncAzureOpenAIÚAzureOpenAI)ÚMetadata)Úoverloadé   )Ú	AssistantÚAssistantEventHandlerÚAssistantStreamManagerÚAssistantToolParamÚAsyncAssistantEventHandlerÚAsyncAssistantStreamManagerÚAsyncCursorPageÚOpenAICreateThreadParamsMessageÚOpenAIMessageÚRunÚSyncCursorPageÚThreadé   )ÚBaseAzureLLMc                   óx   — e Zd ZU eed<   eed<   edz  ed<   edz  ed<   edz  ed<   edz  ed<   ee   dz  ed<   y)	Ú_RunThreadStreamDataÚ	thread_idÚassistant_idNÚadditional_instructionsÚinstructionsÚmetadataÚmodelÚtools)Ú__name__Ú
__module__Ú__qualname__ÚstrÚ__annotations__r   r   r   © ó    úb/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/llms/azure/assistants.pyr   r      sF   … ØƒNØÓØ  4™ZÓ'Ø˜‘*ÓØ˜‰oÓØ�‰:ÓØÐ&Ñ'¨$Ñ.Ô.r+   r   c            &       ó�  ‡ — e Zd ZdAˆ fd„Z	 	 dBdedz  dedz  dedz  dedz  deej                  z  d	edz  d
e	dz  de
dz  de	fd„Z	 	 dBdedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  de
dz  defd„Z	 dCdedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  de
dz  dee   fd„Zededz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  ded   deddee   f   fd„«       Zededz  dedz  dedz  dedz  deej                  z  d	edz  d
e	dz  ded   dz  dee   fd„«       Z	 	 	 dDdedz  dedz  dedz  dedz  deej                  z  d	edz  de
dz  fd„Z	 	 dBdede
dedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  de
dz  defd„Ze	 dCdede
dedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  ded   de
dz  deddef   fd„«       Ze	 dCdede
dedz  dedz  dedz  dedz  deej                  z  d	edz  d
e	dz  ded   dz  de
dz  defd„«       Z	 	 	 dDdede
dedz  dedz  dedz  dedz  deej                  z  d	edz  dedz  de
dz  fd„Z	 	 dBdededz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  de
dz  dee   fd„Ze	 dCdededz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  ded   de
dz  deddee   f   fd„«       Ze	 dCdededz  dedz  dedz  dedz  deej                  z  d	edz  d
e	dz  ded   dz  de
dz  dee   fd„«       Z	 	 	 dDdededz  dedz  dedz  dedz  deej                  z  d	edz  de
dz  fd „Z	 dCd!e
dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  d"ee   dz  de
dz  defd#„Ze	 dCd!e
dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d"ee   dz  d
edz  d$ed   de
dz  deddef   fd%„«       Z e	 dCd!e
dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d"ee   dz  d
e	dz  d$ed   dz  de
dz  defd&„«       Z 	 	 	 dDd!e
dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d"ee   dz  de
dz  fd'„Z 	 dCdededz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  de
dz  defd(„Z!e	 dCdededz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  d)ed   de
dz  deddef   fd*„«       Z"e	 dCdededz  dedz  dedz  dedz  deej                  z  d	edz  d
e	dz  d)ed   dz  de
dz  defd+„«       Z"	 	 	 dDdededz  dedz  dedz  dedz  deej                  z  d	edz  de
dz  fd,„Z"	 dCded-ed.edz  d/edz  d!e
dz  d0edz  d1edz  d2ee#   dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  de
dz  de$f"d3„Z%	 dCd
eded-ed.edz  d/edz  d!e
dz  d0edz  d2ee#   dz  d4e&dz  de
dz  de'e(   fd5„Z)	 dCd
e	ded-ed.edz  d/edz  d!e
dz  d0edz  d2ee#   dz  d4e&dz  de
dz  de*e&   fd6„Z+eded-ed.edz  d/edz  d!e
dz  d0edz  d1edz  d2ee#   dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  d7ed   dedde$f   f"d8„«       Z,eded-ed.edz  d/edz  d!e
dz  d0edz  d1edz  d2ee#   dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d
e	dz  d7ed   dz  de$f"d9„«       Z,	 	 	 	 dEded-ed.edz  d/edz  d!e
dz  d0edz  d1edz  d2ee#   dz  dedz  dedz  dedz  dedz  deej                  z  d	edz  d4e&dz  de
dz  f d:„Z,	 dCdedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  d;e
de
dz  defd<„Z-	 	 	 dDdedz  dedz  dedz  dedz  deej                  z  d	edz  d;e
de
dz  fd=„Z.	 dCdedz  dedz  dedz  dedz  deej                  z  d	edz  d
edz  d-ede
dz  fd>„Z/	 	 	 dDdedz  dedz  dedz  dedz  deej                  z  d	edz  d-ed?edz  de
dz  fd@„Z0ˆ xZ1S )FÚAzureAssistantsAPIÚreturnNc                 ó"   •— t         ‰| �  «        y ©N)ÚsuperÚ__init__)ÚselfÚ	__class__s    €r,   r3   zAzureAssistantsAPI.__init__%   s   ø€ Ü‰ÑÕr+   Úapi_keyÚapi_baseÚapi_versionÚazure_ad_tokenÚtimeoutÚmax_retriesÚclientÚlitellm_paramsc	                 ó^   — |€(| j                  |xs i ||d|d¬«      }	t        di |	¤Ž}
|
S |}
|
S )NÚ F©r=   r6   r7   Ú
model_namer8   Úis_asyncr*   )Úinitialize_azure_sdk_clientr
   ©r4   r6   r7   r8   r9   r:   r;   r<   r=   Úazure_client_paramsÚazure_openai_clients              r,   Úget_azure_clientz#AzureAssistantsAPI.get_azure_client(   s^   € ð ˆ>Ø)-×)IÑ)IØ-Ò3°ØØ!ØØ'Øð *Jó *Ðô #.Ñ"DÐ0CÑ"DÐð #Ð"ð #)Ðà"Ð"r+   c	                 ó^   — |€(| j                  |xs i ||d|d¬«      }	t        di |	¤Ž}
|
S |}
|
S )Nr?   Tr@   r*   )rC   r	   rD   s              r,   Úasync_get_azure_clientz)AzureAssistantsAPI.async_get_azure_clientB   s^   € ð ˆ>Ø)-×)IÑ)IØ-Ò3°ØØ!ØØ'Øð *Jó *Ðô #3Ñ"IÐ5HÑ"IÐð
 #Ð"ð #)Ðà"Ð"r+   c	           
   ƒ   óœ   K  — | j                  ||||||||¬«      }	|	j                  j                  j                  «       ƒ d {  –—† }
|
S 7 Œ­w)N©r6   r7   r8   r9   r:   r;   r<   r=   )rI   ÚbetaÚ
assistantsÚlist)r4   r6   r7   r8   r9   r:   r;   r<   r=   rF   Úresponses              r,   Úasync_get_assistantsz'AzureAssistantsAPI.async_get_assistants`   sa   è ø€ ð &*×%@Ñ%@ØØØ#Ø)ØØ#ØØ)ð &Aó 	&
Ðð !4× 8Ñ 8× CÑ C× HÑ HÓ J×Jˆàˆð Kús   ‚AAÁA
ÁAÚaget_assistantsTc	                  ó   — y r1   r*   ©	r4   r6   r7   r8   r9   r:   r;   r<   rQ   s	            r,   Úget_assistantsz!AzureAssistantsAPI.get_assistants|   ó   € ð 	r+   Fc	                  ó   — y r1   r*   rS   s	            r,   rT   z!AzureAssistantsAPI.get_assistantsŠ   rU   r+   c
           
      ó¾   — |�|du r| j                  ||||||||	¬«      S | j                  ||||||||	¬«      }
|
j                  j                  j	                  «       }|S )NTrK   )r6   r7   r9   r:   r;   r<   r8   r=   )rP   rG   rL   rM   rN   )r4   r6   r7   r8   r9   r:   r;   r<   rQ   r=   rF   rO   s               r,   rT   z!AzureAssistantsAPI.get_assistantsš   s’   € ð Ð&¨?¸dÑ+BØ×,Ñ,ØØ!Ø'Ø-ØØ'ØØ-ð -ó 	ð 	ð &*×%:Ñ%:ØØØ)ØØ#ØØ#Ø)ð &;ó 	&
Ðð .×2Ñ2×=Ñ=×BÑBÓDˆàˆr+   r   Úmessage_datac           
   ƒ   ór  K  — | j                  |||||||	|
¬«      } |j                  j                  j                  j                  |fi |¤Žƒ d {  –—† }d }t        |dd «      €,d|_        t        j                  |j                  «       «      }|S t        j                  |j                  «       «      }|S 7 Œd­w)NrK   ÚstatusÚ	completed)
rI   rL   ÚthreadsÚmessagesÚcreateÚgetattrrZ   r   Úmodel_validateÚdict)r4   r   rX   r6   r7   r8   r9   r:   r;   r<   r=   Úopenai_clientÚthread_messageÚresponse_objs                 r,   Úa_add_messagez AzureAssistantsAPI.a_add_messageÂ   sÑ   è ø€ ð  $×:Ñ:ØØØ#Ø)ØØ#ØØ)ð  ;ó 	 
ˆð 6`°]×5GÑ5G×5OÑ5O×5XÑ5X×5_Ñ5_Øñ6
àñ6
÷ 0
ˆð
 .2ˆÜ�> 8¨TÓ2Ð:Ø$/ˆNÔ!Ü(×7Ñ7¸×8KÑ8KÓ8MÓNˆLð Ðô )×7Ñ7¸×8KÑ8KÓ8MÓNˆLØÐð0
ús   ‚AB7ÁB5ÁA%B7re   c                  ó   — y r1   r*   ©r4   r   rX   r6   r7   r8   r9   r:   r;   r<   re   r=   s               r,   Úadd_messagezAzureAssistantsAPI.add_messageé   ó   € ð 	r+   c                  ó   — y r1   r*   rg   s               r,   rh   zAzureAssistantsAPI.add_messageú   ri   r+   c                 ó˜  — |
�|
du r| j                  |||||||||	|¬«
      S | j                  |||||||	|¬«      } |j                  j                  j                  j
                  |fi |¤Ž}d }t        |dd «      €,d|_        t        j                  |j                  «       «      }|S t        j                  |j                  «       «      }|S )NT)
r   rX   r6   r7   r8   r9   r:   r;   r<   r=   rK   rZ   r[   )re   rG   rL   r\   r]   r^   r_   rZ   r   r`   ra   )r4   r   rX   r6   r7   r8   r9   r:   r;   r<   re   r=   rb   rc   rd   s                  r,   rh   zAzureAssistantsAPI.add_message  s  € ð Ð$¨¸$Ñ)>Ø×%Ñ%Ø#Ø)ØØ!Ø'Ø-ØØ'ØØ-ð &ó ð ð  $×4Ñ4ØØØ#Ø)ØØ#ØØ)ð  5ó 	 
ˆð 0Z¨}×/AÑ/A×/IÑ/I×/RÑ/R×/YÑ/YØñ0
àñ0
ˆð
 .2ˆÜ�> 8¨TÓ2Ð:Ø$/ˆNÔ!Ü(×7Ñ7¸×8KÑ8KÓ8MÓNˆLð Ðô )×7Ñ7¸×8KÑ8KÓ8MÓNˆLØÐr+   c
           
   ƒ   ó´   K  — | j                  ||||||||	¬«      }
|
j                  j                  j                  j	                  |¬«      ƒ d {  –—† }|S 7 Œ­w©NrK   ©r   )rI   rL   r\   r]   rN   ©r4   r   r6   r7   r8   r9   r:   r;   r<   r=   rb   rO   s               r,   Úasync_get_messagesz%AzureAssistantsAPI.async_get_messages@  sk   è ø€ ð  $×:Ñ:ØØØ#Ø)ØØ#ØØ)ð  ;ó 	 
ˆð !.× 2Ñ 2× :Ñ :× CÑ C× HÑ HÐS\Ð HÓ ]×]ˆàˆð ^ús   ‚AAÁAÁAÚaget_messagesc                  ó   — y r1   r*   ©r4   r   r6   r7   r8   r9   r:   r;   r<   rq   r=   s              r,   Úget_messageszAzureAssistantsAPI.get_messages]  ó   € ð 	r+   c                  ó   — y r1   r*   rs   s              r,   rt   zAzureAssistantsAPI.get_messagesm  ru   r+   c                 óØ   — |	�|	du r| j                  |||||||||
¬«	      S | j                  ||||||||
¬«      }|j                  j                  j                  j                  |¬«      }|S ©NT)	r   r6   r7   r8   r9   r:   r;   r<   r=   rK   rn   )rp   rG   rL   r\   r]   rN   )r4   r   r6   r7   r8   r9   r:   r;   r<   rq   r=   rb   rO   s                r,   rt   zAzureAssistantsAPI.get_messages  sŸ   € ð Ð$¨¸$Ñ)>Ø×*Ñ*Ø#ØØ!Ø'Ø-ØØ'ØØ-ð +ó 
ð 
ð  $×4Ñ4ØØØ#Ø)ØØ#ØØ)ð  5ó 	 
ˆð (×,Ñ,×4Ñ4×=Ñ=×BÑBÈYÐBÓWˆàˆr+   r"   r]   c           
   ƒ   ó  K  — | j                  ||||||||
¬«      }i }|	�|	|d<   |�||d<    |j                  j                  j                  di |¤Žƒ d {  –—† }t	        j
                  |j                  «       «      S 7 Œ'­w)NrK   r]   r"   r*   )rI   rL   r\   r^   r   r`   ra   )r4   r"   r6   r7   r8   r9   r:   r;   r<   r]   r=   rb   ÚdataÚmessage_threads                 r,   Úasync_create_threadz&AzureAssistantsAPI.async_create_thread©  s    è ø€ ð  $×:Ñ:ØØØ#Ø)ØØ#ØØ)ð  ;ó 	 
ˆð ˆØÐØ'ˆD�ÑØÐØ'ˆD�Ñà&G m×&8Ñ&8×&@Ñ&@×&GÑ&GÑ&OÈ$Ñ&O× Oˆä×$Ñ$ ^×%8Ñ%8Ó%:Ó;Ð;ð !Pús   ‚AA?ÁA=Á(A?Úacreate_threadc                  ó   — y r1   r*   ©r4   r"   r6   r7   r8   r9   r:   r;   r]   r<   r}   r=   s               r,   Úcreate_threadz AzureAssistantsAPI.create_threadÍ  ri   r+   c                  ó   — y r1   r*   r   s               r,   r€   z AzureAssistantsAPI.create_threadÞ  ri   r+   c                 ó(  — |
�|
du r| j                  ||||||||	||¬«
      S | j                  |||||||	|¬«      }i }|�||d<   |�||d<    |j                  j                  j                  di |¤Ž}t        j                  |j                  «       «      S )a-  
        Here's an example:
        ```
        from litellm.llms.openai.openai import OpenAIAssistantsAPI, MessageData

        # create thread
        message: MessageData = {"role": "user", "content": "Hey, how's it going?"}
        openai_api.create_thread(messages=[message])
        ```
        T)
r"   r6   r7   r8   r9   r:   r;   r<   r]   r=   rK   r]   r"   r*   )r|   rG   rL   r\   r^   r   r`   ra   )r4   r"   r6   r7   r8   r9   r:   r;   r]   r<   r}   r=   rF   rz   r{   s                  r,   r€   z AzureAssistantsAPI.create_threadñ  sÚ   € ð0 Ð%¨.¸DÑ*@Ø×+Ñ+Ø!ØØ!Ø'Ø-ØØ'ØØ!Ø-ð ,ó ð ð &*×%:Ñ%:ØØØ#Ø)ØØ#ØØ)ð &;ó 	&
Ðð ˆØÐØ'ˆD�ÑØÐØ'ˆD�Ñà GÐ 3× 8Ñ 8× @Ñ @× GÑ GÑ OÈ$Ñ Oˆä×$Ñ$ ^×%8Ñ%8Ó%:Ó;Ð;r+   c
           
   ƒ   óâ   K  — | j                  ||||||||	¬«      }
|
j                  j                  j                  |¬«      ƒ d {  –—† }t	        j
                  |j                  «       «      S 7 Œ'­wrm   )rI   rL   r\   Úretriever   r`   ra   ro   s               r,   Úasync_get_threadz#AzureAssistantsAPI.async_get_thread+  sv   è ø€ ð  $×:Ñ:ØØØ#Ø)ØØ#ØØ)ð  ;ó 	 
ˆð !.× 2Ñ 2× :Ñ :× CÑ CÈiÐ CÓ X×Xˆä×$Ñ$ X§]¡]£_Ó5Ð5ð Yús   ‚AA/ÁA-Á(A/Úaget_threadc                  ó   — y r1   r*   ©r4   r   r6   r7   r8   r9   r:   r;   r<   r†   r=   s              r,   Ú
get_threadzAzureAssistantsAPI.get_threadH  ru   r+   c                  ó   — y r1   r*   rˆ   s              r,   r‰   zAzureAssistantsAPI.get_threadX  ru   r+   c                 ó  — |	�|	du r| j                  |||||||||
¬«	      S | j                  ||||||||
¬«      }|j                  j                  j	                  |¬«      }t        j                  |j                  «       «      S rx   )r…   rG   rL   r\   r„   r   r`   ra   )r4   r   r6   r7   r8   r9   r:   r;   r<   r†   r=   rb   rO   s                r,   r‰   zAzureAssistantsAPI.get_threadj  s«   € ð Ð" {°dÑ':Ø×(Ñ(Ø#ØØ!Ø'Ø-ØØ'ØØ-ð )ó 
ð 
ð  $×4Ñ4ØØØ#Ø)ØØ#ØØ)ð  5ó 	 
ˆð (×,Ñ,×4Ñ4×=Ñ=È	Ð=ÓRˆä×$Ñ$ X§]¡]£_Ó5Ð5r+   r   r    r!   r#   Ústreamr$   c           
   ƒ   óÀ   K  — | j                  |	|
||||||¬«      }|j                  j                  j                  j	                  |||||||¬«      ƒ d {  –—† }|S 7 Œ­w)N)r6   r7   r:   r;   r8   r9   r<   r=   ©r   r   r    r!   r"   r#   r$   )rI   rL   r\   ÚrunsÚcreate_and_poll)r4   r   r   r    r!   r"   r#   rŒ   r$   r6   r7   r8   r9   r:   r;   r<   r=   rb   rO   s                      r,   Úarun_threadzAzureAssistantsAPI.arun_thread—  s…   è ø€ ð&  $×:Ñ:ØØØØ#Ø#Ø)ØØ)ð  ;ó 	 
ˆð !.× 2Ñ 2× :Ñ :× ?Ñ ?× OÑ OØØ%Ø$;Ø%ØØØð !Pó !
÷ 
ˆð ˆð
ús   ‚AAÁAÁAÚevent_handlerc                 ó„   — |||||||dœ}|	�|	|d<    |j                   j                  j                  j                  di |¤ŽS ©NrŽ   r’   r*   ©rL   r\   r�   rŒ   )r4   r<   r   r   r    r!   r"   r#   r$   r’   r=   rz   s               r,   Úasync_run_thread_streamz*AzureAssistantsAPI.async_run_thread_streamÁ  sX   € ð #Ø(Ø'>Ø(Ø ØØñ'
ˆð Ð$Ø$1ˆD�Ñ!Ø.ˆv�{‰{×"Ñ"×'Ñ'×.Ñ.Ñ6°Ñ6Ð6r+   c                 ó–   — |j                   j                  j                  j                  }|||||||dœ}|	� |di |¤d|	i¤ŽS  |di |¤ŽS r”   r•   )r4   r<   r   r   r    r!   r"   r#   r$   r’   r=   Ú	stream_fnÚ	base_datas                r,   Úrun_thread_streamz$AzureAssistantsAPI.run_thread_streamÛ  sd   € ð "Ÿ;™;×.Ñ.×3Ñ3×:Ñ:ˆ	à"Ø(Ø'>Ø(Ø ØØñ2
ˆ	ð Ð$ÙÑF˜yÑF¸ÒFÐFÙÑ%˜9Ñ%Ð%r+   r‘   c                  ó   — y r1   r*   ©r4   r   r   r    r!   r"   r#   rŒ   r$   r6   r7   r8   r9   r:   r;   r<   r‘   s                    r,   Ú
run_threadzAzureAssistantsAPI.run_threadø  ó   € ð( 	r+   c                  ó   — y r1   r*   rœ   s                    r,   r�   zAzureAssistantsAPI.run_thread  rž   r+   c                 ó¨  — |�_|du r[|�8|du r4| j                  |	|
||||||¬«      }| j                  ||||||||||¬«
      S | j                  |||||||||	|
||||||¬«      S | j                  |	|
||||||¬«      }|�|du r| j	                  ||||||||||¬«
      S |j
                  j                  j                  j                  |||||||¬«      }|S )NTrK   )
r<   r   r   r    r!   r"   r#   r$   r’   r=   )r   r   r    r!   r"   r#   rŒ   r$   r6   r7   r8   r9   r:   r;   r<   r=   rŽ   )	rI   r–   r‘   rG   rš   rL   r\   r�   r�   )r4   r   r   r    r!   r"   r#   rŒ   r$   r6   r7   r8   r9   r:   r;   r<   r‘   r’   r=   Úazure_clientrb   rO   s                         r,   r�   zAzureAssistantsAPI.run_thread&  s†  € ð* Ð" {°dÑ':ØÐ! f°¡nØ&*×&AÑ&AØ#Ø%Ø +Ø#1Ø#Ø +Ø!Ø#1ð 'Bó 	'�ð ×3Ñ3Ø'Ø'Ø!-Ø,CØ!-Ø%ØØØ"/Ø#1ð 4ó ð ð ×#Ñ#Ø#Ø)Ø(?Ø)Ø!ØØØØØ!Ø'Ø-ØØ'ØØ-ð! $ó ð ð$  $×4Ñ4ØØØ#Ø)ØØ#ØØ)ð  5ó 	 
ˆð Ð &¨D¡.Ø×)Ñ)Ø$Ø#Ø)Ø(?Ø)Ø!ØØØ+Ø-ð *ó ð ð (×,Ñ,×4Ñ4×9Ñ9×IÑIØØ%Ø$;Ø%ØØØð Jó 
ˆð ˆr+   Úcreate_assistant_datac
           
   ƒ   ó    K  — | j                  ||||||||	¬«      }
 |
j                  j                  j                  di |¤Žƒ d {  –—† }|S 7 Œ­w)NrK   r*   )rI   rL   rM   r^   )r4   r6   r7   r8   r9   r:   r;   r<   r¢   r=   rF   rO   s               r,   Úasync_create_assistantsz*AzureAssistantsAPI.async_create_assistants‹  sk   è ø€ ð &*×%@Ñ%@ØØØ#Ø)ØØ#ØØ)ð &Aó 	&
Ðð !KÐ 3× 8Ñ 8× CÑ C× JÑ JÑ cÐMbÑ c×cˆØˆð dúó   ‚AAÁAÁAc                 óÄ   — |	�|	du r| j                  |||||||||
¬«	      S | j                  ||||||||
¬«      } |j                  j                  j                  di |¤Ž}|S )NT)	r6   r7   r8   r9   r:   r;   r<   r¢   r=   rK   r*   )r¤   rG   rL   rM   r^   )r4   r6   r7   r8   r9   r:   r;   r¢   r<   r¤   r=   rF   rO   s                r,   Úcreate_assistantsz$AzureAssistantsAPI.create_assistants¥  s    € ð #Ð.Ð3JÈdÑ3RØ×/Ñ/ØØ!Ø'Ø-ØØ'ØØ&;Ø-ð 0ó 
ð 
ð &*×%:Ñ%:ØØØ#Ø)ØØ#ØØ)ð &;ó 	&
Ðð EÐ-×2Ñ2×=Ñ=×DÑDÑ]ÐG\Ñ]ˆØˆr+   c
           
   ƒ   ó    K  — | j                  ||||||||	¬«      }
|
j                  j                  j                  |¬«      ƒ d {  –—† }|S 7 Œ­w)NrK   ©r   )rI   rL   rM   Údelete)r4   r6   r7   r8   r9   r:   r;   r<   r   r=   rF   rO   s               r,   Úasync_delete_assistantz)AzureAssistantsAPI.async_delete_assistantÍ  sg   è ø€ ð &*×%@Ñ%@ØØØ#Ø)ØØ#ØØ)ð &Aó 	&
Ðð !4× 8Ñ 8× CÑ C× JÑ JÐXdÐ JÓ e×eˆØˆð fúr¥   Úasync_delete_assistantsc                 óÄ   — |�|du r| j                  |||||||	||
¬«	      S | j                  |||||||	|
¬«      }|j                  j                  j	                  |¬«      }|S )NT)	r6   r7   r8   r9   r:   r;   r<   r   r=   rK   r©   )r«   rG   rL   rM   rª   )r4   r6   r7   r8   r9   r:   r;   r   r¬   r<   r=   rF   rO   s                r,   Údelete_assistantz#AzureAssistantsAPI.delete_assistantç  sœ   € ð #Ð.Ð3JÈdÑ3RØ×.Ñ.ØØ!Ø'Ø-ØØ'ØØ)Ø-ð /ó 
ð 
ð &*×%:Ñ%:ØØØ#Ø)ØØ#ØØ)ð &;ó 	&
Ðð .×2Ñ2×=Ñ=×DÑDÐR^ÐDÓ_ˆØˆr+   )r/   N)NNr1   )NNN)NNNN)2r%   r&   r'   r3   r(   ÚfloatÚhttpxÚTimeoutÚintr
   ra   rG   r	   rI   r   r   rP   r   r   r   rT   r   r   re   rh   Úboolrp   rt   r   r   r   r|   r€   r…   r‰   r   r   r‘   r   r   r   r–   r   rš   r�   r¤   r§   r«   r®   Ú__classcell__)r5   s   @r,   r.   r.   $   s”  ø„ õð &*Ø&*ñ#à�t‘ð#ð ˜‘*ð#ð ˜4‘Zð	#ð
 ˜d™
ð#ð ˜Ÿ™Ñ&ð#ð ˜4‘Zð#ð ˜dÑ"ð#ð ˜t™ð#ð 
ó#ðD +/Ø&*ñ#à�t‘ð#ð ˜‘*ð#ð ˜4‘Zð	#ð
 ˜d™
ð#ð ˜Ÿ™Ñ&ð#ð ˜4‘Zð#ð ! 4Ñ'ð#ð ˜t™ð#ð 
ó#ðN '+ñà�t‘ðð ˜‘*ðð ˜4‘Zð	ð
 ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ˜t™ðð 
˜Ñ	#óð8 ðà�t‘ðð ˜‘*ðð ˜4‘Zð	ð
 ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ! ™ðð 
�4˜˜¨yÑ9Ð9Ñ	:òó ðð ðà�t‘ðð ˜‘*ðð ˜4‘Zð	ð
 ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ˜dÑ"ðð ! ™¨$Ñ.ðð 
˜	Ñ	"òó ðð. ØØ&*ñ$à�t‘ð$ð ˜‘*ð$ð ˜4‘Zð	$ð
 ˜d™
ð$ð ˜Ÿ™Ñ&ð$ð ˜4‘Zð$ð ˜t™ó$ðd +/Ø&*ñ#àð#ð ð#ð �t‘ð	#ð
 ˜‘*ð#ð ˜4‘Zð#ð ˜d™
ð#ð ˜Ÿ™Ñ&ð#ð ˜4‘Zð#ð ! 4Ñ'ð#ð ˜t™ð#ð 
ó#ðN ð '+ñàðð ðð �t‘ð	ð
 ˜‘*ðð ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ˜t‘}ðð ˜t™ðð 
�4˜˜}Ð,Ñ	-òó ðð  ð '+ñàðð ðð �t‘ð	ð
 ˜‘*ðð ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ˜dÑ"ðð ˜u‘~¨Ñ,ðð ˜t™ðð 
òó ðð8 Ø%)Ø&*ñ1àð1ð ð1ð �t‘ð	1ð
 ˜‘*ð1ð ˜4‘Zð1ð ˜d™
ð1ð ˜Ÿ™Ñ&ð1ð ˜4‘Zð1ð ˜d‘{ð1ð ˜t™ó1ðx +/Ø&*ñàðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ˜t™ðð 
˜Ñ	'óð: ð '+ñàðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ˜t‘}ðð ˜t™ðð 
�4˜˜¨}Ñ=Ð=Ñ	>òó ðð ð '+ñàðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ˜dÑ"ðð ˜u‘~¨Ñ,ðð ˜t™ðð 
˜Ñ	&òó ðð4 ØØ&*ñ&àð&ð �t‘ð&ð ˜‘*ð	&ð
 ˜4‘Zð&ð ˜d™
ð&ð ˜Ÿ™Ñ&ð&ð ˜4‘Zð&ð ˜t™ó&ðj '+ñ <à˜‘+ð <ð �t‘ð <ð ˜‘*ð	 <ð
 ˜4‘Zð <ð ˜d™
ð <ð ˜Ÿ™Ñ&ð <ð ˜4‘Zð <ð ! 4Ñ'ð <ð Ð:Ñ;¸dÑBð <ð ˜t™ð <ð 
ó <ðH ð '+ñà˜‘+ðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð Ð:Ñ;¸dÑBðð ! 4Ñ'ðð   ™ðð ˜t™ðð 
�4˜˜vÐ%Ñ	&òó ðð  ð '+ñà˜‘+ðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð Ð:Ñ;¸dÑBðð ˜dÑ"ðð   ™¨Ñ-ðð ˜t™ðð 
òó ðð8 ØØ&*ñ8<à˜‘+ð8<ð �t‘ð8<ð ˜‘*ð	8<ð
 ˜4‘Zð8<ð ˜d™
ð8<ð ˜Ÿ™Ñ&ð8<ð ˜4‘Zð8<ð Ð:Ñ;¸dÑBð8<ð ˜t™ó8<ðH '+ñ6àð6ð �t‘ð6ð ˜‘*ð	6ð
 ˜4‘Zð6ð ˜d™
ð6ð ˜Ÿ™Ñ&ð6ð ˜4‘Zð6ð ! 4Ñ'ð6ð ˜t™ð6ð 
ó6ð: ð '+ñàðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ˜T‘]ðð ˜t™ðð 
�4˜˜vÐ%Ñ	&òó ðð ð '+ñàðð �t‘ðð ˜‘*ð	ð
 ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ˜dÑ"ðð ˜U‘^ dÑ*ðð ˜t™ðð 
òó ðð4 ØØ&*ñ&6àð&6ð �t‘ð&6ð ˜‘*ð	&6ð
 ˜4‘Zð&6ð ˜d™
ð&6ð ˜Ÿ™Ñ&ð&6ð ˜4‘Zð&6ð ˜t™ó&6ð| '+ñ#(àð(ð ð(ð "% t¡ð	(ð
 ˜D‘jð(ð ˜‘+ð(ð �T‰zð(ð �t‘ð(ð Ð*Ñ+¨dÑ2ð(ð �t‘ð(ð ˜‘*ð(ð ˜4‘Zð(ð ˜d™
ð(ð ˜Ÿ™Ñ&ð(ð ˜4‘Zð(ð  ! 4Ñ'ð!(ð" ˜t™ð#(ð$ 
ó%(ðj '+ñ7à ð7ð ð7ð ð	7ð
 "% t¡ð7ð ˜D‘jð7ð ˜‘+ð7ð �T‰zð7ð Ð*Ñ+¨dÑ2ð7ð -¨tÑ3ð7ð ˜t™ð7ð 
%Ð%?Ñ	@ó7ðJ '+ñ&àð&ð ð&ð ð	&ð
 "% t¡ð&ð ˜D‘jð&ð ˜‘+ð&ð �T‰zð&ð Ð*Ñ+¨dÑ2ð&ð -¨tÑ3ð&ð ˜t™ð&ð 
 Ð 5Ñ	6ó&ð: ðàðð ðð "% t¡ð	ð
 ˜D‘jðð ˜‘+ðð �T‰zðð �t‘ðð Ð*Ñ+¨dÑ2ðð �t‘ðð ˜‘*ðð ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð  ! 4Ñ'ð!ð" ˜T‘]ð#ð$ 
�4˜˜s�?Ñ	#ò%ó ðð* ðàðð ðð "% t¡ð	ð
 ˜D‘jðð ˜‘+ðð �T‰zðð �t‘ðð Ð*Ñ+¨dÑ2ðð �t‘ðð ˜‘*ðð ˜4‘Zðð ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð  ˜dÑ"ð!ð" ˜U‘^ dÑ*ð#ð$ 
ò%ó ððN ØØ6:Ø&*ñ'bàðbð ðbð "% t¡ð	bð
 ˜D‘jðbð ˜‘+ðbð �T‰zðbð �t‘ðbð Ð*Ñ+¨dÑ2ðbð �t‘ðbð ˜‘*ðbð ˜4‘Zðbð ˜d™
ðbð ˜Ÿ™Ñ&ðbð ˜4‘Zðbð$ -¨tÑ3ð%bð& ˜t™ó'bð^ '+ñà�t‘ðð ˜‘*ðð ˜4‘Zð	ð
 ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð  $ðð ˜t™ðð 
óðF Ø $Ø&*ñ%à�t‘ð%ð ˜‘*ð%ð ˜4‘Zð	%ð
 ˜d™
ð%ð ˜Ÿ™Ñ&ð%ð ˜4‘Zð%ð  $ð%ð ˜t™ó%ðd '+ñà�t‘ðð ˜‘*ðð ˜4‘Zð	ð
 ˜d™
ðð ˜Ÿ™Ñ&ðð ˜4‘Zðð ! 4Ñ'ðð ðð ˜t™óðF 04ØØ&*ñ%à�t‘ð%ð ˜‘*ð%ð ˜4‘Zð	%ð
 ˜d™
ð%ð ˜Ÿ™Ñ&ð%ð ˜4‘Zð%ð ð%ð "&¨¡ð%ð ˜t™÷%r+   r.   )!Úcollections.abcr   r   Útypingr   r   r   r   r°   Úopenair	   r
   Ú#openai.types.shared_params.metadatar   Útyping_extensionsr   Útypes.llms.openair   r   r   r   r   r   r   r   r   r   r   r   Úcommon_utilsr   r   r.   r*   r+   r,   ú<module>r¼      sM   ðß /ß 1Ó 1ã ß 0Ý 8Ý &÷÷ ÷ ó õ 'ô/˜9ô /ôh˜õ hr+   