
    i^                    6   d Z ddlmZ ddlmZmZ ddlmZ ddlm	Z	m
Z
 ddlmZmZ ddlmZ dd	lmZmZmZmZmZ dd
lZddlmZ dd
lZddlmZ ddlmZmZmZ ddlmZm Z m!Z!m"Z" ddl#m$Z$  ejJ                  e&      Z'ejP                  rddl)m*Z*  G d de      Z+y
)zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.   )BaseSDK    )modelsutils)HookContext)OptionalNullableUNSET)eventstreamingget_security_from_env)unmarshal_json_response)AnyListMappingOptionalUnionN)AsyncGenerator)defaultdict)ResponseStartedEventConversationEventsDataInputEntries)	RunResultRunResultEventsFunctionResultEventreconstitue_entries)run_requirements)
RunContextc            "          e Zd ZdZeeeeeeedddf	dddeej                  ej                  f   de
e   de
eeej                     eej                     f      de
eej                  ej                   f      d	e
e   d
e
e   de
ej$                     dee   dee   deeeef      defd       Zeeeeeeedddf	dddeej                  ej                  f   de
e   de
eeej                     eej                     f      de
eej                  ej                   f      d	e
e   d
e
e   de
ej$                     dee   dee   deeeef      deeeef   df   fd       Zdeeeeeeeeeedddddeej                  ej                  f   dee   de
e   de
ej8                     de
e   de
eeej                     eej                     f      de
eej                  ej                   f      d	e
e   d
e
e   de
e   de
e   de
ej$                     dee   dee   deeeef      dej:                  f dZdeeeeeeeeeedddddeej                  ej                  f   dee   de
e   de
ej8                     de
e   de
eeej                     eej                     f      de
eej                  ej                   f      d	e
e   d
e
e   de
e   de
e   de
ej$                     dee   dee   deeeef      dej:                  f dZddedddddee   dee   de
ej$                     dee   dee   deeeef      deej@                     fd Z!ddedddddee   dee   de
ej$                     dee   dee   deeeef      deej@                     fd!Z"edddd"d#ede
ej$                     dee   dee   deeeef      dejF                  fd$Z$edddd"d#ede
ej$                     dee   dee   deeeef      dejF                  fd%Z%dd&d'dedddd(d#edeej                  ej                  f   dee   dee   deejL                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      dej:                  fd)Z'dd&d'dedddd(d#edeej                  ej                  f   dee   dee   deejL                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      dej:                  fd*Z(edddd"d#ede
ej$                     dee   dee   deeeef      dejR                  fd+Z*edddd"d#ede
ej$                     dee   dee   deeeef      dejR                  fd,Z+edddd"d#ede
ej$                     dee   dee   deeeef      dejX                  fd-Z-edddd"d#ede
ej$                     dee   dee   deeeef      dejX                  fd.Z.dd&d'dedddd(d#edeej                  ej                  f   d/edee   dee   deej^                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      dej:                  fd0Z0dd&d'dedddd(d#edeej                  ej                  f   d/edee   dee   deej^                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      dej:                  fd1Z1d&eeeeeeeeeedddddeej                  ej                  f   dee   de
e   de
ejd                     de
e   de
eeejf                     eejh                     f      de
eej                  ej                   f      d	e
e   d
e
e   de
e   de
e   de
ej$                     dee   dee   deeeef      de5jl                  ejn                     f d2Z8d&eeeeeeeeeedddddeej                  ej                  f   dee   de
e   de
ejd                     de
e   de
eeejf                     eejh                     f      de
eej                  ej                   f      d	e
e   d
e
e   de
e   de
e   de
ej$                     dee   dee   deeeef      de5jr                  ejn                     f d3Z:d&d&d'dedddd(d#edeej                  ej                  f   dee   dee   deejv                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      de5jl                  ejn                     fd4Z<d&d&d'dedddd(d#edeej                  ej                  f   dee   dee   deejv                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      de5jr                  ejn                     fd5Z=d&d&d'dedddd(d#edeej                  ej                  f   d/edee   dee   deej|                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      de5jl                  ejn                     fd6Z?d&d&d'dedddd(d#edeej                  ej                  f   d/edee   dee   deej|                     deeej                  ej                   f      de
ej$                     dee   dee   deeeef      de5jr                  ejn                     fd7Z@y)8Conversationsz(beta) Conversations APINrun_ctxr   inputsinstructionstoolscompletion_argsnamedescriptionretries
server_url
timeout_mshttp_headersreturnc                 H  K   ddl m} ddlm} ddlm}  | || j                        |||||       d{   \  }}}	 |j                  g | j                  d||||||	|
d| d{   }|j                  |_        |j                  |_        t        j                  d|j                          n(| j                  |j                  |||	|
	       d{   }|xj                  d
z  c_        |j                  j                  |j                          ||j                        }|st        j!                  d       	 |S |j#                  |       d{   }|j                  j                  |       t%        j&                  t(        t*           |      }X7 b7 27 7 Jw)zRun a conversation with the given inputs and context.

        The execution of a run will only stop when no required local execution can be done.r   Beta_validate_runget_function_callsbeta_clientr   r    r!   r"   r#   Nr    r)   r$   r%   r&   r'   r(   &Started Run with conversation with id conversation_idr    r&   r'   r(   r   !No more function calls to execute )mistralai.betar-   mistralai.extra.run.contextr/   mistralai.extra.run.toolsr1   sdk_configurationr7   start_asyncloggerinfoappend_asyncrequest_countoutput_entriesextendoutputsdebugexecute_function_callstypingcastlistr   )selfr   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r-   r/   r1   req
run_resultinput_entriesresfcallsfresultss                        U/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/mistralai/conversations.py	run_asynczConversations.run_async,   s    , 	(=@/<T334%+0
 *
&Z &&.,D,, 	(!- +#))	 	 	 .1-@-@
**-*=*='<S=P=P<QR !--$+$;$;(#)) .   !!Q&!%%,,S[[9'4F@A
  ")!?!?!GG))00: &D,> IE *
	  HsH   4F"F2F")F*A,F"FA>F"F AF"F"F" F"c                    	
K   ddl m} ddlm} ddlm  | | j                        ||||       d{   \  dt        t        t        t        f   df   f 	
fd} |       S 7 <w)	zSimilar to `run_async` but returns a generator which streams events.

        The last streamed object is the RunResult object which summarises what happened in the run.r   r,   r.   r0   r2   Nr*   c                   K   } 	 t        t              }j                  # j                  d
| 	d d {   }n(j	                  j                  |        d {   }|2 3 d {   }t        |j                  t              rdj                  X|j                  j                  _        |j                  j                  _        t        j                  dj                          t        |j                  dd       x}	 ||   j                  |j                         t        j                  t        |       7 7 7 6 xj                  dz  c_        t!        |      }j"                  j%                  |        
|      }|st        j'                  d       nj)                  |       d {  7  }j"                  j%                  |       |D ]2  }t        dt+        d|j,                  |j.                        	       4 t        j                  t        t0           |      } 7 y w)Nr4   r6   r5   output_indexr   r8   zfunction.result)typeresulttool_call_id)eventdatar9   )r   rJ   r7   start_stream_asyncappend_stream_async
isinstancer[   r   r?   r@   getattrappendrH   rI   r   rB   r   rC   rD   rF   rG   r   rX   rY   r   )current_entriesreceived_event_trackerrO   rZ   rV   rE   rP   rQ   fresultr%   r1   r)   rN   r$   rL   r&   r   rM   rK   r'   r(   s            rR   run_generatorz5Conversations.run_stream_async.<locals>.run_generator   s>     ,O  % ' **2 7 7 7 	!.%1!$/ '#-#-	! 	! 	C !% 8 8(/(?(?. '#-#- !9 ! C $' > >%"5::/CD#33;5:ZZ5O5O
227**2L2L/DWE\E\D]^ )0

ND(QQ!" /|<CCEJJO ++ou==A	>3 %%*%-.DE))009+G4LL!DE%,%C%CF%KKKH--44X>#+ -"3!4%6'.~~-4-A-A"  '-kk$|2Dh&OOs t sU   <IE (I(E)I/E3E4E7CIIEA0IGB I)r:   r-   r;   r/   r<   r1   r=   r   r   r   r   )rK   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r-   r/   rd   r1   rN   rL   rM   s   ``    ``````   @@@@rR   run_stream_asynczConversations.run_stream_asynct   s     , 	(=@/<T334%+0
 *
&Z>	5)!;<dBC>	 >	 >	@ S*
s   4BA?=BF)streamstorehandoff_executionr!   r"   r#   r$   r%   agent_idmodelr&   r'   r(   r)   rf   rg   rh   ri   rj   c                   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  t        j                  |t        j                        ||||t        j                  |t        t        t        j                              t        j                  |t        t        j                           ||	|
|      | j                  dd||ddddd|| j                   j                  fd	|
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t!        |t
        j"                        r|g df}| j%                  t'        | j                   |xs ddg t)        | j                   j                  t        j*                              |g d|      }d}t        j,                  |dd      rt/        t        j0                  |      S t        j,                  |dd      r0t/        t        j2                  |      }t        j4                  ||      t        j,                  |dd      r,t        j6                  |      }t        j8                  d||      t        j,                  |dd      r,t        j6                  |      }t        j8                  d||      t        j8                  d|      )  Create a conversation and append entries to it.

        Create a new conversation, using a base model or an agent and append entries. Completion and tool executions are run and the response is appended to the conversation.Use the returned conversation_id to continue the conversation.

        :param inputs:
        :param stream:
        :param store:
        :param handoff_execution:
        :param instructions:
        :param tools:
        :param completion_args:
        :param name:
        :param description:
        :param agent_id:
        :param model:
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nr    rf   rg   rh   r!   r"   r#   r$   r%   ri   rj   POST/v1/conversationsTF
user-agentapplication/jsonc                  R    t        j                   dddt        j                        S NFjsonr   serialize_request_bodyr   ConversationRequestrequests   rR   <lambda>z%Conversations.start.<locals>.<lambda>-  #    (D(Dvv/I/I)     methodpathbase_urlurl_variablesry   request_body_requiredrequest_has_path_paramsrequest_has_query_paramsuser_agent_headeraccept_header_valuer)   securityget_serialized_bodyr(   429500502503504 !agents_api_v1_conversations_startconfigr   operation_idoauth2_scopessecurity_source4224XX5XXhook_ctxry   error_status_codesretry_config200r   r   *API error occurredr   Unexpected response received)r=   r(   _get_urlr   rw   r   get_pydantic_modelConversationInputsr   r   ToolsCompletionArgs_build_requestr   r	   r   r^   RetryConfig
do_requestr   r   Securitymatch_responser   ConversationResponseHTTPValidationErrorDataHTTPValidationErrorstream_to_textSDKErrorrK   r    rf   rg   rh   r!   r"   r#   r$   r%   ri   rj   r&   r'   r(   r)   r   r   rL   r   http_resresponse_datahttp_res_textry   s                          @rR   startzConversations.start   s   V //::J!!H}}X}=H,,++FF4M4MN/%**52B4CU2VW!44!1&2G2G!H #
  !!$'"&$)%)* 2%++44! "! " 
& e%%22%?00==gu001#%HIL?? --!R@  5**33V__! 4% # 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c                  K   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  t        j                  |t        j                        ||||t        j                  |t        t        t        j                              t        j                  |t        t        j                           ||	|
|      | j                  dd||ddddd|| j                   j                  fd	|
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t!        |t
        j"                        r|g df}| j%                  t'        | j                   |xs ddg t)        | j                   j                  t        j*                              |g d|       d{   }d}t        j,                  |dd      rt/        t        j0                  |      S t        j,                  |dd      r0t/        t        j2                  |      }t        j4                  ||      t        j,                  |dd      r4t        j6                  |       d{   }t        j8                  d||      t        j,                  |dd      r4t        j6                  |       d{   }t        j8                  d||      t        j8                  d|      7 +7 7 6w)rl   Nrm   rn   ro   TFrp   rq   c                  R    t        j                   dddt        j                        S rs   ru   rx   s   rR   rz   z+Conversations.start_async.<locals>.<lambda>  r{   r|   r}   r   r   r   r   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   rw   r   r   r   r   r   r   r   _build_request_asyncr   r	   r   r^   r   do_request_asyncr   r   r   r   r   r   r   r   stream_to_text_asyncr   r   s                          @rR   r>   zConversations.start_async[  s    V //::J!!H}}X}=H,,++FF4M4MN/%**52B4CU2VW!44!1&2G2G!H #
  ''$'"&$)%)* 2%++44! "! ( 
& e%%22%?00==gu001#%HIL.. --!R@  5**33V__! 4% / 
 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGG=
0 G Gs8   GK9K2B-K95K56A
K9 K72K95K97K9r   d   )page	page_sizer&   r'   r(   r)   r   r   c                   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  ||      }	| j                  dd|||	ddddd|| j                   j                  |	      }
|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                        r|g d
f}| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |
g d|      }d}t        j                   |dd      r!t#        t$        t        j&                     |      S t        j                   |dd      r0t#        t        j(                  |      }t        j*                  ||      t        j                   |dd      r,t        j,                  |      }t        j.                  d||      t        j                   |dd      r,t        j,                  |      }t        j.                  d||      t        j.                  d|      a  List all created conversations.

        Retrieve a list of conversation entities sorted by creation time.

        :param page:
        :param page_size:
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        N)r   r   GETro   FTrp   rq   r~   r   r   r   ry   r   r   r   r   r   r)   r   r(   r   r    agents_api_v1_conversations_listr   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   #AgentsAPIV1ConversationsListRequestr   r   r	   r   r^   r   r   r   r   r   r   r   r   r   ResponseBodyr   r   r   r   rK   r   r   r&   r'   r(   r)   r   r   ry   rL   r   r   r   r   s                  rR   rJ   zConversations.list  s5   * //::J!!H}}X}=H<<

 !!$'"'$)%)* 2%++44! " 
  e%%22%?00==gu001#%HIL?? --!R?  5**33V__! 4% # 
 "%1CD*40C0C+DhOO%1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c                  K   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  ||      }	| j                  dd|||	ddddd|| j                   j                  |	      }
|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                        r|g d
f}| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |
g d|       d{   }d}t        j                   |dd      r!t#        t$        t        j&                     |      S t        j                   |dd      r0t#        t        j(                  |      }t        j*                  ||      t        j                   |dd      r4t        j,                  |       d{   }t        j.                  d||      t        j                   |dd      r4t        j,                  |       d{   }t        j.                  d||      t        j.                  d|      7 27 7 6wr   )r=   r(   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   s                  rR   
list_asynczConversations.list_async7  sY    * //::J!!H}}X}=H<<

 ''$'"'$)%)* 2%++44! ( 
  e%%22%?00==gu001#%HIL.. --!R?  5**33V__! 4% / 
 
 "%1CD*40C0C+DhOO%1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGG=
0 G Gs8   D<I7>I0?B4I73I34A
I7>I5?2I73I75I7)r&   r'   r(   r)   r7   c                   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  |      }| j                  dd|||ddddd|| j                   j                  |	      }	|t        k(  r2| j                   j                  t        ur| j                   j                  }d}
t        |t        j                        r|g d
f}
| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |	g d|
      }d}t        j                   |dd      rt#        t        j$                  |      S t        j                   |dd      r0t#        t        j&                  |      }t        j(                  ||      t        j                   |dd      r,t        j*                  |      }t        j,                  d||      t        j                   |dd      r,t        j*                  |      }t        j,                  d||      t        j,                  d|      a8  Retrieve a conversation information.

        Given a conversation_id retrieve a conversation entity with its attributes.

        :param conversation_id: ID of the conversation from which we are fetching metadata.
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nr7   r   #/v1/conversations/{conversation_id}FTrp   rq   r   r   r   agents_api_v1_conversations_getr   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   "AgentsAPIV1ConversationsGetRequestr   r   r	   r   r^   r   r   r   r   r   r   r   r   5AgentsAPIV1ConversationsGetResponseV1ConversationsGetr   r   r   r   rK   r7   r&   r'   r(   r)   r   r   ry   rL   r   r   r   r   s                 rR   getzConversations.get  s4   & //::J!!H}}X}=H;;+
 !!6'"'$(%)* 2%++44! " 
  e%%22%?00==gu001#%HIL?? --!R>  5**33V__! 4% # 
 "%1CD*LLh  %1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c                  K   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  |      }| j                  dd|||ddddd|| j                   j                  |	      }	|t        k(  r2| j                   j                  t        ur| j                   j                  }d}
t        |t        j                        r|g d
f}
| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |	g d|
       d{   }d}t        j                   |dd      rt#        t        j$                  |      S t        j                   |dd      r0t#        t        j&                  |      }t        j(                  ||      t        j                   |dd      r4t        j*                  |       d{   }t        j,                  d||      t        j                   |dd      r4t        j*                  |       d{   }t        j,                  d||      t        j,                  d|      7 +7 7 6wr   )r=   r(   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   r   r   s                 rR   	get_asynczConversations.get_async  sY    & //::J!!H}}X}=H;;+
 ''6'"'$(%)* 2%++44! ( 
  e%%22%?00==gu001#%HIL.. --!R>  5**33V__! 4% / 
 
 "%1CD*LLh  %1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGGA
4 G G8   D;I/=I(>B-I/+I+,A
I/6I-72I/+I/-I/Tserver)rf   rg   rh   r#   r&   r'   r(   r)   c       
         n   d}d}|	| j                   j                  }	||}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                                       | j                  dd||ddddd|
| j                   j                  fd	|	
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g d|      }d}t        j*                  |dd      rt-        t        j.                  |      S t        j*                  |dd      r0t-        t        j0                  |      }t        j2                  ||      t        j*                  |dd      r,t        j4                  |      }t        j6                  d||      t        j*                  |dd      r,t        j4                  |      }t        j6                  d||      t        j6                  d|      )A  Append new entries to an existing conversation.

        Run completion on the history of the conversation and the user entries. Return the new created entries.

        :param conversation_id: ID of the conversation to which we append entries.
        :param inputs:
        :param stream:
        :param store: Whether to store the results into our servers or not.
        :param handoff_execution:
        :param completion_args: White-listed arguments from the completion API
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nr    rf   rg   rh   r#   r7   conversation_append_requestrn   r   Trp   rq   c                  f    t        j                   j                  dddt        j                        S rs   r   rv   r   r   ConversationAppendRequestrx   s   rR   rz   z&Conversations.append.<locals>.<lambda>  -    (D(D3300) r|   r}   r   r   "agents_api_v1_conversations_appendr   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   %AgentsAPIV1ConversationsAppendRequestr   r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   rK   r7   r    rf   rg   rh   r#   r&   r'   r(   r)   r   r   rL   r   r   r   r   ry   s                     @rR   r`   zConversations.appendI  s   B //::J!!H}}X}=H>>+(.(H(H//8Q8QR"3 % 8 8#Xf.C.C%D!)
 !!6'"&$(%)* 2%++44! ") " 
. e%%22%?00==gu001#%HIL?? --!RA  5**33V__! 4% # 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c       
           K   d}d}|	| j                   j                  }	||}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                                       | j                  dd||ddddd|
| j                   j                  fd	|	
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g d|       d{   }d}t        j*                  |dd      rt-        t        j.                  |      S t        j*                  |dd      r0t-        t        j0                  |      }t        j2                  ||      t        j*                  |dd      r4t        j4                  |       d{   }t        j6                  d||      t        j*                  |dd      r4t        j4                  |       d{   }t        j6                  d||      t        j6                  d|      7 +7 7 6w)r   Nr   r   rn   r   Trp   rq   c                  f    t        j                   j                  dddt        j                        S rs   r   rx   s   rR   rz   z,Conversations.append_async.<locals>.<lambda>  r   r|   r}   r   r   r   r   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   r   r   r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   r   s                     @rR   rA   zConversations.append_async  s    B //::J!!H}}X}=H>>+(.(H(H//8Q8QR"3 % 8 8#Xf.C.C%D!)
 ''6'"&$(%)* 2%++44! ") ( 
. e%%22%?00==gu001#%HIL.. --!RA  5**33V__! 4% / 
 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGG=
0 G Gs8   F#K&K'B-KKA
KK 2KKKc                   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  |      }| j                  dd|||ddddd|| j                   j                  |	      }	|t        k(  r2| j                   j                  t        ur| j                   j                  }d}
t        |t        j                        r|g d
f}
| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |	g d|
      }d}t        j                   |dd      rt#        t        j$                  |      S t        j                   |dd      r0t#        t        j&                  |      }t        j(                  ||      t        j                   |dd      r,t        j*                  |      }t        j,                  d||      t        j                   |dd      r,t        j*                  |      }t        j,                  d||      t        j,                  d|      a  Retrieve all entries in a conversation.

        Given a conversation_id retrieve all the entries belonging to that conversation. The entries are sorted in the order they were appended, those can be messages, connectors or function_call.

        :param conversation_id: ID of the conversation from which we are fetching entries.
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nr   r   z+/v1/conversations/{conversation_id}/historyFTrp   rq   r   r   r   #agents_api_v1_conversations_historyr   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   &AgentsAPIV1ConversationsHistoryRequestr   r   r	   r   r^   r   r   r   r   r   r   r   r   ConversationHistoryr   r   r   r   r   s                 rR   get_historyzConversations.get_history7  s-   & //::J!!H}}X}=H??+
 !!>'"'$(%)* 2%++44! " 
  e%%22%?00==gu001#%HIL?? --!RB  5**33V__! 4% # 
 "%1CD*6+E+ExPP%1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c                  K   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  |      }| j                  dd|||ddddd|| j                   j                  |	      }	|t        k(  r2| j                   j                  t        ur| j                   j                  }d}
t        |t        j                        r|g d
f}
| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |	g d|
       d{   }d}t        j                   |dd      rt#        t        j$                  |      S t        j                   |dd      r0t#        t        j&                  |      }t        j(                  ||      t        j                   |dd      r4t        j*                  |       d{   }t        j,                  d||      t        j                   |dd      r4t        j*                  |       d{   }t        j,                  d||      t        j,                  d|      7 +7 7 6wr   )r=   r(   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   r   r   s                 rR   get_history_asynczConversations.get_history_async  sQ    & //::J!!H}}X}=H??+
 ''>'"'$(%)* 2%++44! ( 
  e%%22%?00==gu001#%HIL.. --!RB  5**33V__! 4% / 
 
 "%1CD*6+E+ExPP%1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGG=
0 G Gr   c                   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  |      }| j                  dd|||ddddd|| j                   j                  |	      }	|t        k(  r2| j                   j                  t        ur| j                   j                  }d}
t        |t        j                        r|g d
f}
| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |	g d|
      }d}t        j                   |dd      rt#        t        j$                  |      S t        j                   |dd      r0t#        t        j&                  |      }t        j(                  ||      t        j                   |dd      r,t        j*                  |      }t        j,                  d||      t        j                   |dd      r,t        j*                  |      }t        j,                  d||      t        j,                  d|      a  Retrieve all messages in a conversation.

        Given a conversation_id retrieve all the messages belonging to that conversation. This is similar to retrieving all entries except we filter the messages only.

        :param conversation_id: ID of the conversation from which we are fetching messages.
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nr   r   z,/v1/conversations/{conversation_id}/messagesFTrp   rq   r   r   r   $agents_api_v1_conversations_messagesr   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   'AgentsAPIV1ConversationsMessagesRequestr   r   r	   r   r^   r   r   r   r   r   r   r   r   ConversationMessagesr   r   r   r   r   s                 rR   get_messageszConversations.get_messages  s-   & //::J!!H}}X}=H@@+
 !!?'"'$(%)* 2%++44! " 
  e%%22%?00==gu001#%HIL?? --!RC  5**33V__! 4% # 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c                  K   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  |      }| j                  dd|||ddddd|| j                   j                  |	      }	|t        k(  r2| j                   j                  t        ur| j                   j                  }d}
t        |t        j                        r|g d
f}
| j                  t        | j                   |xs ddg t        | j                   j                  t        j                              |	g d|
       d{   }d}t        j                   |dd      rt#        t        j$                  |      S t        j                   |dd      r0t#        t        j&                  |      }t        j(                  ||      t        j                   |dd      r4t        j*                  |       d{   }t        j,                  d||      t        j                   |dd      r4t        j*                  |       d{   }t        j,                  d||      t        j,                  d|      7 +7 7 6wr   )r=   r(   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   r   r   s                 rR   get_messages_asyncz Conversations.get_messages_asyncB  sQ    & //::J!!H}}X}=H@@+
 ''?'"'$(%)* 2%++44! ( 
  e%%22%?00==gu001#%HIL.. --!RC  5**33V__! 4% / 
 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGG=
0 G Gr   from_entry_idc                p   d}d}|
| j                   j                  }
|	|	}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                           |            | j                  dd||ddddd|| j                   j                  fd	|

      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g d|      }d}t        j*                  |dd      rt-        t        j.                  |      S t        j*                  |dd      r0t-        t        j0                  |      }t        j2                  ||      t        j*                  |dd      r,t        j4                  |      }t        j6                  d||      t        j*                  |dd      r,t        j4                  |      }t        j6                  d||      t        j6                  d|      )  Restart a conversation starting from a given entry.

        Given a conversation_id and an id, recreate a conversation from this point and run completion. A new conversation is returned with the new entries returned.

        :param conversation_id: ID of the original conversation which is being restarted.
        :param inputs:
        :param from_entry_id:
        :param stream:
        :param store: Whether to store the results into our servers or not.
        :param handoff_execution:
        :param completion_args: White-listed arguments from the completion API
        :param retries: Override the default retry configuration for this method
        :param server_url: Override the default server URL for this method
        :param timeout_ms: Override the default request timeout configuration for this method in milliseconds
        :param http_headers: Additional headers to set or replace on requests.
        Nr    rf   rg   rh   r#   r   r7   conversation_restart_requestrn   +/v1/conversations/{conversation_id}/restartTrp   rq   c                  f    t        j                   j                  dddt        j                        S rs   r   rv   r   r   ConversationRestartRequestrx   s   rR   rz   z'Conversations.restart.<locals>.<lambda>  -    (D(D4411) r|   r}   r   r   #agents_api_v1_conversations_restartr   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   &AgentsAPIV1ConversationsRestartRequestr   r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   rK   r7   r    r   rf   rg   rh   r#   r&   r'   r(   r)   r   r   rL   r   r   r   r   ry   s                      @rR   restartzConversations.restart  s   F //::J!!H}}X}=H??+)/)J)J//8Q8QR"3 % 8 8#Xf.C.C%D! ,	*
 !!>'"&$(%)* 2%++44! ") " 
. e%%22%?00==gu001#%HIL?? --!RB  5**33V__! 4% # 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5!00:M//"6-PP%5!00:M//"6-PPoo<hGGr|   c                  K   d}d}|
| j                   j                  }
|	|	}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                           |            | j                  dd||ddddd|| j                   j                  fd	|

      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g d|       d{   }d}t        j*                  |dd      rt-        t        j.                  |      S t        j*                  |dd      r0t-        t        j0                  |      }t        j2                  ||      t        j*                  |dd      r4t        j4                  |       d{   }t        j6                  d||      t        j*                  |dd      r4t        j4                  |       d{   }t        j6                  d||      t        j6                  d|      7 +7 7 6w)r   Nr   r   rn   r   Trp   rq   c                  f    t        j                   j                  dddt        j                        S rs   r   rx   s   rR   rz   z-Conversations.restart_async.<locals>.<lambda>]  r   r|   r}   r   r   r   r   r   r   r   r   r   r   r   r   r   )r=   r(   r   r   r   r   r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r   r   r   r   r   r   r   s                      @rR   restart_asynczConversations.restart_async  s    F //::J!!H}}X}=H??+)/)J)J//8Q8QR"3 % 8 8#Xf.C.C%D! ,	*
 ''>'"&$(%)* 2%++44! ") ( 
. e%%22%?00==gu001#%HIL.. --!RB  5**33V__! 4% / 
 
 "%1CD*6+F+FQQ%1CD3..M ,,]HEE%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PPoo<hGG=
0 G Gs8   F$K'K(B-KKA
K K!2KKKc                
   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  t        j                  |t        j                        ||||t        j                  |t        t        t        j                              t        j                  |t        t        j                           ||	|
|      | j                  dd||ddddd|| j                   j                  fd	|
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t!        |t
        j"                        r|g df}| j%                  t'        | j                   |xs ddg t)        | j                   j                  t        j*                              |g dd|      }d}t        j,                  |dd      rt/        j0                  |d |       S t        j,                  |dd      rGt        j2                  |      }t5        t        j6                  ||      }t        j8                  |||      t        j,                  |dd      r,t        j2                  |      }t        j:                  d||      t        j,                  |dd      r,t        j2                  |      }t        j:                  d||      t        j2                  |      }t        j:                  d||      )rl   Nrm   rn   /v1/conversations#streamTFrp   text/event-streamc                  R    t        j                   dddt        j                        S rs   r   rv   r   ConversationStreamRequestrx   s   rR   rz   z,Conversations.start_stream.<locals>.<lambda>  #    (D(Dvv/O/O) r|   r}   r   r   (agents_api_v1_conversations_start_streamr   r   r   ry   r   rf   r   r   c                 J    t        j                  | t        j                        S Nr   unmarshal_jsonr   ConversationEventsraws    rR   rz   z,Conversations.start_stream.<locals>.<lambda>
      E00f6O6OP r|   
client_refr   rq   r   r   r   r   r   )r=   r(   r   r   r
  r   r   r   r   r   ConversationStreamRequestToolsr   r   r   r	   r   r^   r   r   r   r   r   r   r
   EventStreamr   r   r   r   r   r   s                          @rR   start_streamzConversations.start_stream  s   ` //::J!!H}}X}=H22++FF4M4MN/%**'V-R-R(ST "44!1&2G2G!H #
$ !!+'"&$)%)* 3%++44! "! " 
& e%%22%?00==gu001#%HIL?? --!RG  5**33V__! 4% # 
  "%1DE!--P 
 %1CD!00:M3..-M ,,]HmTT%5!00:M//"6-PP%5!00:M//"6-PP,,X6oo<hVVr|   c                z  K   d}d}|| j                   j                  }||}n| j                  ||      }t        j                  t        j                  |t        j                        ||||t        j                  |t        t        t        j                              t        j                  |t        t        j                           ||	|
|      | j                  dd||ddddd|| j                   j                  fd	|
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t!        |t
        j"                        r|g df}| j%                  t'        | j                   |xs ddg t)        | j                   j                  t        j*                              |g dd|       d{   }d}t        j,                  |dd      rt/        j0                  |d |       S t        j,                  |dd      rOt        j2                  |       d{   }t5        t        j6                  ||      }t        j8                  |||      t        j,                  |dd      r4t        j2                  |       d{   }t        j:                  d||      t        j,                  |dd      r4t        j2                  |       d{   }t        j:                  d||      t        j2                  |       d{   }t        j:                  d||      7 g7 7 7 W7 %w)rl   Nrm   rn   r  TFrp   r  c                  R    t        j                   dddt        j                        S rs   r	  rx   s   rR   rz   z2Conversations.start_stream_async.<locals>.<lambda>v  r  r|   r}   r   r   r  r   r   r  r   c                 J    t        j                  | t        j                        S r  r  r  s    rR   rz   z2Conversations.start_stream_async.<locals>.<lambda>  r  r|   r  r   rq   r   r   r   r   r   )r=   r(   r   r   r
  r   r   r   r   r   r  r   r   r   r	   r   r^   r   r   r   r   r   r   r
   EventStreamAsyncr   r   r   r   r   r   s                          @rR   r\   z Conversations.start_stream_async  s    ` //::J!!H}}X}=H22++FF4M4MN/%**'V-R-R(ST "44!1&2G2G!H #
$ ''+'"&$)%)* 3%++44! "! ( 
& e%%22%?00==gu001#%HIL.. --!RG  5**33V__! 4% / 
 
  "%1DE!22P 
 %1CD"'"<"<X"FFM3..-M ,,]HmTT%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PP#88BBoo<hVVK
0 G G G Cs]   GL;L/	A%L;.L2/A%L;L5A
L;L7 3L;L9L;2L;5L;7L;9L;c       
            d}d}|	| j                   j                  }	||}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                                       | j                  dd||ddddd|
| j                   j                  fd	|	
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g dd|      }d}t        j*                  |dd      rt-        j.                  |d |       S t        j*                  |dd      rGt        j0                  |      }t3        t        j4                  ||      }t        j6                  |||      t        j*                  |dd      r,t        j0                  |      }t        j8                  d||      t        j*                  |dd      r,t        j0                  |      }t        j8                  d||      t        j0                  |      }t        j8                  d||      )r   Nr   r7   "conversation_append_stream_requestrn   */v1/conversations/{conversation_id}#streamTrp   r  c                  f    t        j                   j                  dddt        j                        S rs   r   rv   r!  r   ConversationAppendStreamRequestrx   s   rR   rz   z-Conversations.append_stream.<locals>.<lambda>  -    (D(D::66) r|   r}   r   r   )agents_api_v1_conversations_append_streamr   r   r  r   c                 J    t        j                  | t        j                        S r  r  r  s    rR   rz   z-Conversations.append_stream.<locals>.<lambda>  r  r|   r  r   rq   r   r   r   r   r   )r=   r(   r   r   +AgentsAPIV1ConversationsAppendStreamRequestr%  r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r
   r  r   r   r   r   r   r   s                     @rR   append_streamzConversations.append_stream  s   B //::J!!H}}X}=HDD+/5/U/U//8Q8QR"3 % 8 8#Xf.C.C%D!0
 !!='"&$(%)* 3%++44! ") " 
. e%%22%?00==gu001#%HIL?? --!RH  5**33V__! 4% # 
  "%1DE!--P 
 %1CD!00:M3..-M ,,]HmTT%5!00:M//"6-PP%5!00:M//"6-PP,,X6oo<hVVr|   c       
         8  K   d}d}|	| j                   j                  }	||}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                                       | j                  dd||ddddd|
| j                   j                  fd	|	
      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g dd|       d{   }d}t        j*                  |dd      rt-        j.                  |d |       S t        j*                  |dd      rOt        j0                  |       d{   }t3        t        j4                  ||      }t        j6                  |||      t        j*                  |dd      r4t        j0                  |       d{   }t        j8                  d||      t        j*                  |dd      r4t        j0                  |       d{   }t        j8                  d||      t        j0                  |       d{   }t        j8                  d||      7 g7 7 7 W7 %w)r   Nr   r   rn   r"  Trp   r  c                  f    t        j                   j                  dddt        j                        S rs   r$  rx   s   rR   rz   z3Conversations.append_stream_async.<locals>.<lambda>n  r&  r|   r}   r   r   r'  r   r   r  r   c                 J    t        j                  | t        j                        S r  r  r  s    rR   rz   z3Conversations.append_stream_async.<locals>.<lambda>  r  r|   r  r   rq   r   r   r   r   r   )r=   r(   r   r   r)  r%  r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r
   r  r   r   r   r   r   r   s                     @rR   r]   z!Conversations.append_stream_async)  s    B //::J!!H}}X}=HDD+/5/U/U//8Q8QR"3 % 8 8#Xf.C.C%D!0
 ''='"&$(%)* 3%++44! ") ( 
. e%%22%?00==gu001#%HIL.. --!RH  5**33V__! 4% / 
 
  "%1DE!22P 
 %1CD"'"<"<X"FFM3..-M ,,]HmTT%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PP#88BBoo<hVVK
0 G G G Cs]   F$L'L(A%LLA%L3L4A
L>L?3L2L3LLLLLc                   d}d}|
| j                   j                  }
|	|	}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                           |            | j                  dd||ddddd|| j                   j                  fd	|

      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g dd|      }d}t        j*                  |dd      rt-        j.                  |d |       S t        j*                  |dd      rGt        j0                  |      }t3        t        j4                  ||      }t        j6                  |||      t        j*                  |dd      r,t        j0                  |      }t        j8                  d||      t        j*                  |dd      r,t        j0                  |      }t        j8                  d||      t        j0                  |      }t        j8                  d||      )r   Nr   r7   #conversation_restart_stream_requestrn   2/v1/conversations/{conversation_id}/restart#streamTrp   r  c                  f    t        j                   j                  dddt        j                        S rs   r   rv   r0  r    ConversationRestartStreamRequestrx   s   rR   rz   z.Conversations.restart_stream.<locals>.<lambda>  -    (D(D;;77) r|   r}   r   r   *agents_api_v1_conversations_restart_streamr   r   r  r   c                 J    t        j                  | t        j                        S r  r  r  s    rR   rz   z.Conversations.restart_stream.<locals>.<lambda>	  r  r|   r  r   rq   r   r   r   r   r   )r=   r(   r   r   ,AgentsAPIV1ConversationsRestartStreamRequestr4  r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r
   r  r   r   r   r   r   r   s                      @rR   restart_streamzConversations.restart_stream  s   F //::J!!H}}X}=HEE+060W0W//8Q8QR"3 % 8 8#Xf.C.C%D! ,	1
 !!E'"&$(%)* 3%++44! ") " 
. e%%22%?00==gu001#%HIL?? --!RI  5**33V__! 4% # 
  "%1DE!--P 
 %1CD!00:M3..-M ,,]HmTT%5!00:M//"6-PP%5!00:M//"6-PP,,X6oo<hVVr|   c                :  K   d}d}|
| j                   j                  }
|	|	}n| j                  ||      }t        j                  |t        j
                  t        j                  |t        j                        |||t        j                  |t        t        j                           |            | j                  dd||ddddd|| j                   j                  fd	|

      }|t        k(  r2| j                   j                  t        ur| j                   j                  }d}t        |t        j                         r|g df}| j#                  t%        | j                   |xs ddg t'        | j                   j                  t        j(                              |g dd|       d{   }d}t        j*                  |dd      rt-        j.                  |d |       S t        j*                  |dd      rOt        j0                  |       d{   }t3        t        j4                  ||      }t        j6                  |||      t        j*                  |dd      r4t        j0                  |       d{   }t        j8                  d||      t        j*                  |dd      r4t        j0                  |       d{   }t        j8                  d||      t        j0                  |       d{   }t        j8                  d||      7 g7 7 7 W7 %w)r   Nr   r/  rn   r1  Trp   r  c                  f    t        j                   j                  dddt        j                        S rs   r3  rx   s   rR   rz   z4Conversations.restart_stream_async.<locals>.<lambda>p	  r5  r|   r}   r   r   r6  r   r   r  r   c                 J    t        j                  | t        j                        S r  r  r  s    rR   rz   z4Conversations.restart_stream_async.<locals>.<lambda>	  r  r|   r  r   rq   r   r   r   r   r   )r=   r(   r   r   r8  r4  r   r   r   r   r   r   r   r	   r   r^   r   r   r   r   r   r   r
   r  r   r   r   r   r   r   s                      @rR   restart_stream_asyncz"Conversations.restart_stream_async(	  s    F //::J!!H}}X}=HEE+060W0W//8Q8QR"3 % 8 8#Xf.C.C%D! ,	1
 ''E'"&$(%)* 3%++44! ") ( 
. e%%22%?00==gu001#%HIL.. --!RI  5**33V__! 4% / 
 
  "%1DE!22P 
 %1CD"'"<"<X"FFM3..-M ,,]HmTT%5"'"<"<X"FFM//"6-PP%5"'"<"<X"FFM//"6-PP#88BBoo<hVVK
0 G G G Cs]   F%L(L)A%LLA%L4L5A
L?L 3L3L4LLLLL)A__name__
__module____qualname____doc__r   r	   r   r   r   ConversationInputsTypedDictr   strr   r   ToolsTypedDictr   CompletionArgsTypedDictr   r   r   intr   r   rS   r   r   re   boolHandoffExecutionr   r   r>   r   rJ   r   r   r   r   )ConversationAppendRequestHandoffExecutionr`   rA   r   r   r   r   r   r   *ConversationRestartRequestHandoffExecutionr  r  )ConversationStreamRequestHandoffExecutionr  'ConversationStreamRequestToolsTypedDictr
   r  r  r  r  r\   /ConversationAppendStreamRequestHandoffExecutionr*  r]   0ConversationRestartStreamRequestHandoffExecutionr9  r=  r9   r|   rR   r   r   &   s   #
 
 /4  &+-27<$($(48!EE f//1S1SSTE 's+	E
  $v||$d6+@+@&AAB
E *&'')G)GGH
E s#E &c*E "%"3"34E SME SME  wsCx01!E" 
#E EN 
 /4  &+-27<$($(48!bb f//1S1SSTb 's+	b
  $v||$d6+@+@&AAB
b *&'')G)GGH
b s#b &c*b "%"3"34b SMb SMb  wsCx01!b" 
oy894?	@#b bT "'(-GL.3  &+-2*/',7<$($(48+~H f//1S1SST~H 	~H
  %~H ,F,C,CD~H 's+~H  $v||$d6+@+@&AAB
~H *&'')G)GGH
~H s#~H &c*~H  #3'!~H"  $#~H$ "%"3"34%~H& SM'~H( SM)~H* wsCx01+~H, 
	$	$-~HH "'(-GL.3  &+-2*/',7<$($(48+~H f//1S1SST~H 	~H
  %~H ,F,C,CD~H 's+~H  $v||$d6+@+@&AAB
~H *&'')G)GGH
~H s#~H &c*~H  #3'!~H"  $#~H$ "%"3"34%~H& SM'~H( SM)~H* wsCx01+~H, 
	$	$-~HF  #&7<$($(48ZH smZH C=	ZH
 "%"3"34ZH SMZH SMZH wsCx01ZH 
f!!	"ZH~  #&7<$($(48ZH smZH C=	ZH
 "%"3"34ZH SMZH SMZH wsCx01ZH 
f!!	"ZH@ 8=$($(48YH YH "%"3"34	YH
 SMYH SMYH wsCx01YH 
	E	EYH~ 8=$($(48YH YH "%"3"34	YH
 SMYH SMYH wsCx01YH 
	E	EYH@ "' $  7<$($(48!uH uH f//1S1SST	uH
 uH ~uH $<<
uH "&'')G)GGH
uH "%"3"34uH SMuH SMuH  wsCx01!uH" 
	$	$#uHx "' $  7<$($(48!uH uH f//1S1SST	uH
 uH ~uH $<<
uH "&'')G)GGH
uH "%"3"34uH SMuH SMuH  wsCx01!uH" 
	$	$#uHv 8=$($(48WH WH "%"3"34	WH
 SMWH SMWH wsCx01WH 
	#	#WHz 8=$($(48WH WH "%"3"34	WH
 SMWH SMWH wsCx01WH 
	#	#WHz 8=$($(48WH WH "%"3"34	WH
 SMWH SMWH wsCx01WH 
	$	$WHz 8=$($(48WH WH "%"3"34	WH
 SMWH SMWH wsCx01WH 
	$	$WH~ "' $  7<$($(48#xH xH f//1S1SST	xH
 xH xH ~xH $==
xH "&'')G)GGH
xH "%"3"34xH SMxH  SM!xH" wsCx01#xH$ 
	$	$%xH@ "' $  7<$($(48#xH xH f//1S1SST	xH
 xH xH ~xH $==
xH "&'')G)GGH
xH "%"3"34xH SMxH  SM!xH" wsCx01#xH$ 
	$	$%xH| "&(- .3  &+-2*/',7<$($(485LW f//1S1SSTLW 	LW
  %LW ,<<
LW 's+LW  V::;VCCDF
LW  *&'')G)GGH
!LW& s#'LW( &c*)LW* #3'+LW,  $-LW. "%"3"34/LW0 SM1LW2 SM3LW4 wsCx015LW6 
	#	#F$=$=	>7LWd "&(- .3  &+-2*/',7<$($(485LW f//1S1SSTLW 	LW
  %LW ,<<
LW 's+LW  V::;VCCDF
LW  *&'')G)GGH
!LW& s#'LW( &c*)LW* #3'+LW,  $-LW. "%"3"34/LW0 SM1LW2 SM3LW4 wsCx015LW6 
	(	()B)B	C7LWf "& $  7<$($(48!|W |W f//1S1SST	|W
 |W ~|W $BB
|W "&'')G)GGH
|W "%"3"34|W SM|W SM|W  wsCx01!|W" 
	#	#F$=$=	>#|WF "& $  7<$($(48!|W |W f//1S1SST	|W
 |W ~|W $BB
|W "&'')G)GGH
|W "%"3"34|W SM|W SM|W  wsCx01!|W" 
	(	()B)B	C#|WH "& $  7<$($(48#W W f//1S1SST	W
 W W ~W $CC
W "&'')G)GGH
W "%"3"34W SMW  SM!W" wsCx01#W$ 
	#	#F$=$=	>%WN "& $  7<$($(48#W W f//1S1SST	W
 W W ~W $CC
W "&'')G)GGH
W "%"3"34W SMW  SM!W" wsCx01#W$ 
	(	()B)B	C%Wr|   r   ),rA  basesdkr   	mistralair   r   mistralai._hooksr   mistralai.typesr   r	   mistralai.utilsr
   r   'mistralai.utils.unmarshal_json_responser   rH   r   r   r   r   r   r   loggingcollectionsr   mistralai.modelsr   r   r   mistralai.extra.run.resultr   r   r   r   mistralai.extra.run.utilsr   	getLoggerr>  r?   TYPE_CHECKINGr;   r   r   r9   r|   rR   <module>r\     su    G  # ( 3 A K 6 6  !  # 
  7			8	$	6
A&WG A&Wr|   