
    f j                       d dl mZ d dlmZmZmZ d dlmZ d dlm	Z	 d dl
Z
ddlmZ dd	lmZmZmZmZmZmZ dd
lmZmZmZmZmZmZ ddlmZmZmZmZm Z  ddl!m"Z"m#Z#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/m0Z0 ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7 ddl8m9Z9 ddl:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ ddlAmZmZ ddlBmCZC ddgZD G d de)          ZE G d de*          ZF G d d          ZG G d d          ZH G d d           ZI G d! d"          ZJdS )#    )annotations)IterableOptionaloverload)partial)LiteralN   )_legacy_response   )Runs	AsyncRunsRunsWithRawResponseAsyncRunsWithRawResponseRunsWithStreamingResponseAsyncRunsWithStreamingResponse)MessagesAsyncMessagesMessagesWithRawResponseAsyncMessagesWithRawResponseMessagesWithStreamingResponse"AsyncMessagesWithStreamingResponse)	NOT_GIVENBodyQueryHeadersNotGiven)required_argsmaybe_transformasync_maybe_transform)r   r   )cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)StreamAsyncStream)ThreadThreadDeletedAssistantStreamEventthread_create_paramsthread_update_paramsthread_create_and_run_params)make_request_options)AssistantEventHandlerAssistantEventHandlerTAssistantStreamManagerAsyncAssistantEventHandlerAsyncAssistantEventHandlerTAsyncAssistantStreamManager)r   r   )RunThreadsAsyncThreadsc                     e Zd ZedBd            ZedCd            ZedDd            ZedEd	            Zeed
d
d
eddFdZ	d
d
d
eddGdZ
ed
d
d
eddHdZd
d
d
eddId!Zeeeeeeed
d
d
ed"
dJd.            Zeeeeeed
d
d
ed/	dKd2            Zeeeeeed
d
d
ed/	dLd5            Z ed#gd#d'g          eeeeeed
d
d
ed"
dMd7            Zeeeeeed
d
d
ed/	dNd9            Zeeeeeed
d
d
ed/	dOd=            Zeeeeed
d
d
d
ed>
dPdAZd
S )Qr5   returnr   c                *    t          | j                  S N)r   _clientselfs    yC:\Users\Terasoftware\OneDrive\Desktop\faahhh\fyndo\fyndo\venv\Lib\site-packages\openai/resources/beta/threads/threads.pyrunszThreads.runsA   s    DL!!!    r   c                *    t          | j                  S r:   )r   r;   r<   s    r>   messageszThreads.messagesE   s    %%%r@   ThreadsWithRawResponsec                     t          |           S r:   )rC   r<   s    r>   with_raw_responsezThreads.with_raw_responseI   s    %d+++r@   ThreadsWithStreamingResponsec                     t          |           S r:   )rF   r<   s    r>   with_streaming_responsezThreads.with_streaming_responseM   s    +D111r@   NrB   metadataextra_headersextra_query
extra_bodytimeoutrB   1Iterable[thread_create_params.Message] | NotGivenrJ   Optional[object] | NotGivenrK   Headers | NonerL   Query | NonerM   Body | NonerN   'float | httpx.Timeout | None | NotGivenr'   c          
         ddi|pi }|                      dt          ||dt          j                  t	          ||||          t
                    S )	  
        Create a thread.

        Args:
          messages: A list of [messages](https://platform.openai.com/docs/api-reference/messages) to
              start the thread with.

          metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful
              for storing additional information about the object in a structured format. Keys
              can be a maximum of 64 characters long and values can be a maxium of 512
              characters long.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        OpenAI-Betaassistants=v1/threadsrB   rJ   rK   rL   rM   rN   bodyoptionscast_to)_postr   r*   ThreadCreateParamsr-   r'   r=   rB   rJ   rK   rL   rM   rN   s          r>   createzThreads.createQ   s    @ 'QM<ORQzz  ( (  %7  )+Q[el     
 
 	
r@   r[   	thread_idstrc          	         |st          d|          ddi|pi }|                     d| t          ||||          t                    S )G  
        Retrieves a thread.

        Args:
          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        8Expected a non-empty value for `thread_id` but received rW   rX   	/threads/r[   r^   r_   
ValueError_getr-   r'   r=   rd   rK   rL   rM   rN   s         r>   retrievezThreads.retrieve   s    .  	geXaeefff&QM<ORQyy#	##(+Q[el     
 
 	
r@   rJ   rK   rL   rM   rN   c          
         |st          d|          ddi|pi }|                     d| t          d|it          j                  t          ||||          t                    S )  
        Modifies a thread.

        Args:
          metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful
              for storing additional information about the object in a structured format. Keys
              can be a maximum of 64 characters long and values can be a maxium of 512
              characters long.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rh   rW   rX   ri   rJ   r[   r\   )rl   r`   r   r+   ThreadUpdateParamsr-   r'   r=   rd   rJ   rK   rL   rM   rN   s          r>   updatezThreads.update   s    :  	geXaeefff&QM<ORQzz#	## *h!79M9`aa(+Q[el     
 
 	
r@   r(   c          	         |st          d|          ddi|pi }|                     d| t          ||||          t                    S )D  
        Delete a thread.

        Args:
          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rh   rW   rX   ri   r[   rj   rl   _deleter-   r(   rn   s         r>   deletezThreads.delete   s    .  	geXaeefff&QM<ORQ||#	##(+Q[el   "  
 
 	
r@   
instructionsrJ   modelstreamthreadtoolsrK   rL   rM   rN   assistant_idr|   Optional[str] | NotGivenr}   r~   #Optional[Literal[False]] | NotGivenr   .thread_create_and_run_params.Thread | NotGivenr   @Optional[Iterable[thread_create_and_run_params.Tool]] | NotGivenr4   c                   dS a  
        Create a thread and run it in one request.

        Args:
          assistant_id: The ID of the
              [assistant](https://platform.openai.com/docs/api-reference/assistants) to use to
              execute this run.

          instructions: Override the default system message of the assistant. This is useful for
              modifying the behavior on a per-run basis.

          metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful
              for storing additional information about the object in a structured format. Keys
              can be a maximum of 64 characters long and values can be a maxium of 512
              characters long.

          model: The ID of the [Model](https://platform.openai.com/docs/api-reference/models) to
              be used to execute this run. If a value is provided here, it will override the
              model associated with the assistant. If not, the model associated with the
              assistant will be used.

          stream: If `true`, returns a stream of events that happen during the Run as server-sent
              events, terminating when the Run enters a terminal state with a `data: [DONE]`
              message.

          thread: If no thread is provided, an empty thread will be created.

          tools: Override the tools the assistant can use for this run. This is useful for
              modifying the behavior on a per-run basis.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        N r=   r   r|   rJ   r}   r~   r   r   rK   rL   rM   rN   s               r>   create_and_runzThreads.create_and_run   
    p 	r@   	r|   rJ   r}   r   r   rK   rL   rM   rN   Literal[True]Stream[AssistantStreamEvent]c                   dS a  
        Create a thread and run it in one request.

        Args:
          assistant_id: The ID of the
              [assistant](https://platform.openai.com/docs/api-reference/assistants) to use to
              execute this run.

          stream: If `true`, returns a stream of events that happen during the Run as server-sent
              events, terminating when the Run enters a terminal state with a `data: [DONE]`
              message.

          instructions: Override the default system message of the assistant. This is useful for
              modifying the behavior on a per-run basis.

          metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful
              for storing additional information about the object in a structured format. Keys
              can be a maximum of 64 characters long and values can be a maxium of 512
              characters long.

          model: The ID of the [Model](https://platform.openai.com/docs/api-reference/models) to
              be used to execute this run. If a value is provided here, it will override the
              model associated with the assistant. If not, the model associated with the
              assistant will be used.

          thread: If no thread is provided, an empty thread will be created.

          tools: Override the tools the assistant can use for this run. This is useful for
              modifying the behavior on a per-run basis.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        Nr   r=   r   r~   r|   rJ   r}   r   r   rK   rL   rM   rN   s               r>   r   zThreads.create_and_run(  r   r@   bool"Run | Stream[AssistantStreamEvent]c                   dS r   r   r   s               r>   r   zThreads.create_and_runb  r   r@   3Optional[Literal[False]] | Literal[True] | NotGivenc                   ddi|pi }|                      dt          |||||||dt          j                  t	          ||	|
|          t
          |pdt          t                             S NrW   rX   /threads/runsr   r|   rJ   r}   r~   r   r   r[   Fr]   r^   r_   r~   
stream_cls)r`   r   r,   ThreadCreateAndRunParamsr-   r4   r%   r)   r   s               r>   r   zThreads.create_and_run  s    $ 'QM<ORQzz $0$0 ("$$"  -E  )+Q[el   ?U23'  
 
 	
r@   -AssistantStreamManager[AssistantEventHandler]c       
            dS 'Create a thread and stream the run backNr   r=   r   r|   rJ   r}   r   r   rK   rL   rM   rN   s              r>   create_and_run_streamzThreads.create_and_run_stream  	    $ 	r@   event_handlerr/   .AssistantStreamManager[AssistantEventHandlerT]c                   dS r   r   r=   r   r|   rJ   r}   r   r   r   rK   rL   rM   rN   s               r>   r   zThreads.create_and_run_stream  	    & 	r@   
r|   rJ   r}   r   r   r   rK   rL   rM   rN   AssistantEventHandlerT | None^AssistantStreamManager[AssistantEventHandler] | AssistantStreamManager[AssistantEventHandlerT]c                  dd|rdndd|pi }t          | j        dt          ||||d||dt          j                  t          ||	|
|	          t          dt          t                   
          }t          ||pt                                S r   rX   zthreads.create_and_run_streamtruefalse)rW   zX-Stainless-Stream-Helperz X-Stainless-Custom-Event-Handlerr   Tr   r[   r   )r   )r   r`   r   r,   r   r-   r4   r%   r)   r0   r.   )r=   r   r|   rJ   r}   r   r   r   rK   rL   rM   rN   make_requests                r>   r   zThreads.create_and_run_stream  s    & +)H:G0TW
 
 "	
 J $0$0 (""$"  -E  )+Q[el   23)
 
 
, &l-BjShSjSjkkkkr@   )r8   r   )r8   r   )r8   rC   )r8   rF   rB   rO   rJ   rP   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r'   rd   re   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r'   rd   re   rJ   rP   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r'   rd   re   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r(   r   re   r|   r   rJ   rP   r}   r   r~   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r4   )r   re   r~   r   r|   r   rJ   rP   r}   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r~   r   r|   r   rJ   rP   r}   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r~   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r   r   r   r   r   r/   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   __name__
__module____qualname__r    r?   rB   rE   rH   r   rc   ro   ru   rz   r   r   r   r   r   r@   r>   r5   r5   @   ss       " " " _" & & & _& , , , _, 2 2 2 _2 GP09 )-$("&;D.
 .
 .
 .
 .
 .
l )-$("&;D 
  
  
  
  
  
L 1: )-$("&;D'
 '
 '
 '
 '
 '
^ )-$("&;D 
  
  
  
  
  
D 
 2;09*36?AJR[ )-$("&;D7 7 7 7 7 X7r  2;09*3AJR[ )-$("&;D7 7 7 7 7 X7r  2;09*3AJR[ )-$("&;D7 7 7 7 7 X7r ]N#nh%?@@
 2;09*3FOAJR[ )-$("&;D&
 &
 &
 &
 &
 A@&
P 
 2;09*3AJR[ )-$("&;D     X& 
 2;09*3AJR[ )-$("&;D     X0 2;09*3AJR[7; )-$("&;D.l .l .l .l .l .l .l .lr@   c                     e Zd ZedBd            ZedCd            ZedDd            ZedEd	            Zeed
d
d
eddFdZ	d
d
d
eddGdZ
ed
d
d
eddHdZd
d
d
eddId!Zeeeeeeed
d
d
ed"
dJd.            Zeeeeeed
d
d
ed/	dKd2            Zeeeeeed
d
d
ed/	dLd5            Z ed#gd#d'g          eeeeeed
d
d
ed"
dMd7            Zeeeeeed
d
d
ed/	dNd9            Zeeeeeed
d
d
ed/	dOd=            Zeeeeed
d
d
d
ed>
dPdAZd
S )Qr6   r8   r   c                *    t          | j                  S r:   )r   r;   r<   s    r>   r?   zAsyncThreads.runs   s    &&&r@   r   c                *    t          | j                  S r:   )r   r;   r<   s    r>   rB   zAsyncThreads.messages$  s    T\***r@   AsyncThreadsWithRawResponsec                     t          |           S r:   )r   r<   s    r>   rE   zAsyncThreads.with_raw_response(  s    *4000r@   !AsyncThreadsWithStreamingResponsec                     t          |           S r:   )r   r<   s    r>   rH   z$AsyncThreads.with_streaming_response,  s    0666r@   NrI   rB   rO   rJ   rP   rK   rQ   rL   rR   rM   rS   rN   rT   r'   c          
        K   ddi|pi }|                      dt          ||dt          j                   d{V t	          ||||          t
                     d{V S )rV   rW   rX   rY   rZ   Nr[   r\   )r`   r   r*   ra   r-   r'   rb   s          r>   rc   zAsyncThreads.create0  s      @ 'QM<ORQZZ, ( (  %7        )+Q[el      
 
 
 
 
 
 
 
 	
r@   r[   rd   re   c          	        K   |st          d|          ddi|pi }|                     d| t          ||||          t                     d{V S )rg   rh   rW   rX   ri   r[   rj   Nrk   rn   s         r>   ro   zAsyncThreads.retrieve`  s      .  	geXaeefff&QM<ORQYY#	##(+Q[el     
 
 
 
 
 
 
 
 	
r@   rp   c          
        K   |st          d|          ddi|pi }|                     d| t          d|it          j                   d{V t          ||||          t                     d{V S )	rr   rh   rW   rX   ri   rJ   Nr[   r\   )rl   r`   r   r+   rs   r-   r'   rt   s          r>   ru   zAsyncThreads.update  s      :  	geXaeefff&QM<ORQZZ#	##,j(-CEYElmmmmmmmm(+Q[el      
 
 
 
 
 
 
 
 	
r@   r(   c          	        K   |st          d|          ddi|pi }|                     d| t          ||||          t                     d{V S )rw   rh   rW   rX   ri   r[   rj   Nrx   rn   s         r>   rz   zAsyncThreads.delete  s      .  	geXaeefff&QM<ORQ\\#	##(+Q[el   " " 
 
 
 
 
 
 
 
 	
r@   r{   r   r|   r   r}   r~   r   r   r   r   r   r4   c               
   K   dS r   r   r   s               r>   r   zAsyncThreads.create_and_run        p 	r@   r   r   !AsyncStream[AssistantStreamEvent]c               
   K   dS r   r   r   s               r>   r   zAsyncThreads.create_and_run  r   r@   r   'Run | AsyncStream[AssistantStreamEvent]c               
   K   dS r   r   r   s               r>   r   zAsyncThreads.create_and_runA  r   r@   r   c                  K   ddi|pi }|                      dt          |||||||dt          j                   d {V t	          ||	|
|          t
          |pdt          t                              d {V S r   )r`   r   r,   r   r-   r4   r&   r)   r   s               r>   r   zAsyncThreads.create_and_run{  s      $ 'QM<ORQZZ,$0$0 ("$$"  -E        )+Q[el   ?U"#78'   
 
 
 
 
 
 
 
 	
r@   7AsyncAssistantStreamManager[AsyncAssistantEventHandler]c       
            dS r   r   r   s              r>   r   z"AsyncThreads.create_and_run_stream  r   r@   r   r2   8AsyncAssistantStreamManager[AsyncAssistantEventHandlerT]c                   dS r   r   r   s               r>   r   z"AsyncThreads.create_and_run_stream  r   r@   r   "AsyncAssistantEventHandlerT | NonerAsyncAssistantStreamManager[AsyncAssistantEventHandler] | AsyncAssistantStreamManager[AsyncAssistantEventHandlerT]c                  dd|rdndd|pi }|                      dt          ||||d||dt          j                  t	          ||	|
|	          t
          dt          t                   
          }t          ||pt                                S r   )
r`   r   r,   r   r-   r4   r&   r)   r3   r1   )r=   r   r|   rJ   r}   r   r   r   rK   rL   rM   rN   requests                r>   r   z"AsyncThreads.create_and_run_stream  s    , +)H:G0TW
 
 "	
 ** $0$0 (""$"  -E  )+Q[el   "#78'  
 
* +7-BoSmSoSoppppr@   )r8   r   )r8   r   )r8   r   )r8   r   r   r   r   r   r   )r   re   r~   r   r|   r   rJ   rP   r}   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r~   r   r|   r   rJ   rP   r}   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r~   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r   r   r   r   r   r2   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   )r   re   r|   r   rJ   rP   r}   r   r   r   r   r   r   r   rK   rQ   rL   rR   rM   rS   rN   rT   r8   r   r   r   r@   r>   r6   r6     ss       ' ' ' _' + + + _+ 1 1 1 _1 7 7 7 _7 GP09 )-$("&;D.
 .
 .
 .
 .
 .
l )-$("&;D 
  
  
  
  
  
L 1: )-$("&;D'
 '
 '
 '
 '
 '
^ )-$("&;D 
  
  
  
  
  
D 
 2;09*36?AJR[ )-$("&;D7 7 7 7 7 X7r  2;09*3AJR[ )-$("&;D7 7 7 7 7 X7r  2;09*3AJR[ )-$("&;D7 7 7 7 7 X7r ]N#nh%?@@
 2;09*3FOAJR[ )-$("&;D&
 &
 &
 &
 &
 A@&
P 
 2;09*3AJR[ )-$("&;D     X& 
 2;09*3AJR[ )-$("&;D     X0 2;09*3AJR[<@ )-$("&;D0q 0q 0q 0q 0q 0q 0q 0qr@   c                  F    e Zd ZddZedd            Zedd	            Zd
S )rC   threadsr5   r8   Nonec                @   || _         t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        d S r:   )_threadsr
   to_raw_response_wrapperrc   ro   ru   rz   r   r=   r   s     r>   __init__zThreadsWithRawResponse.__init__  s    &>N
 
 )@
 
 '>N
 
 '>N
 
 /F"
 
r@   r   c                4    t          | j        j                  S r:   )r   r   r?   r<   s    r>   r?   zThreadsWithRawResponse.runs  s    "4=#5666r@   r   c                4    t          | j        j                  S r:   )r   r   rB   r<   s    r>   rB   zThreadsWithRawResponse.messages  s    &t}'=>>>r@   Nr   r5   r8   r   )r8   r   )r8   r   r   r   r   r   r    r?   rB   r   r@   r>   rC   rC      sh        
 
 
 
& 7 7 7 _7 ? ? ? _? ? ?r@   rC   c                  F    e Zd ZddZedd            Zedd	            Zd
S )r   r   r6   r8   r   c                @   || _         t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        d S r:   )r   r
   async_to_raw_response_wrapperrc   ro   ru   rz   r   r   s     r>   r   z$AsyncThreadsWithRawResponse.__init__  s    &DN
 
 )F
 
 'DN
 
 'DN
 
 /L"
 
r@   r   c                4    t          | j        j                  S r:   )r   r   r?   r<   s    r>   r?   z AsyncThreadsWithRawResponse.runs1  s    '(:;;;r@   r   c                4    t          | j        j                  S r:   )r   r   rB   r<   s    r>   rB   z$AsyncThreadsWithRawResponse.messages5  s    +DM,BCCCr@   Nr   r6   r8   r   )r8   r   )r8   r   r   r   r@   r>   r   r     sn        
 
 
 
& < < < _< D D D _D D Dr@   r   c                  F    e Zd ZddZedd            Zedd	            Zd
S )rF   r   r5   r8   r   c                   || _         t          |j                  | _        t          |j                  | _        t          |j                  | _        t          |j                  | _        t          |j                  | _        d S r:   )r   r#   rc   ro   ru   rz   r   r   s     r>   r   z%ThreadsWithStreamingResponse.__init__;  s    2N
 
 5
 
 3N
 
 3N
 
 ;"
 
r@   r   c                4    t          | j        j                  S r:   )r   r   r?   r<   s    r>   r?   z!ThreadsWithStreamingResponse.runsN  s    ();<<<r@   r   c                4    t          | j        j                  S r:   )r   r   rB   r<   s    r>   rB   z%ThreadsWithStreamingResponse.messagesR  s    ,T]-CDDDr@   Nr   )r8   r   )r8   r   r   r   r@   r>   rF   rF   :  sn        
 
 
 
& = = = _= E E E _E E Er@   rF   c                  F    e Zd ZddZedd            Zedd	            Zd
S )r   r   r6   r8   r   c                   || _         t          |j                  | _        t          |j                  | _        t          |j                  | _        t          |j                  | _        t          |j                  | _        d S r:   )r   r$   rc   ro   ru   rz   r   r   s     r>   r   z*AsyncThreadsWithStreamingResponse.__init__X  s    8N
 
 ;
 
 9N
 
 9N
 
 A"
 
r@   r   c                4    t          | j        j                  S r:   )r   r   r?   r<   s    r>   r?   z&AsyncThreadsWithStreamingResponse.runsk  s    -dm.@AAAr@   r   c                4    t          | j        j                  S r:   )r   r   rB   r<   s    r>   rB   z*AsyncThreadsWithStreamingResponse.messageso  s    1$-2HIIIr@   Nr   )r8   r   )r8   r   r   r   r@   r>   r   r   W  sr        
 
 
 
& B B B _B J J J _J J Jr@   r   )K
__future__r   typingr   r   r   	functoolsr   typing_extensionsr   httpx r
   r?   r   r   r   r   r   r   rB   r   r   r   r   r   r   _typesr   r   r   r   r   _utilsr   r   r   	runs.runs_compatr    	_resourcer!   r"   	_responser#   r$   
_streamingr%   r&   
types.betar'   r(   r)   r*   r+   r,   _base_clientr-   lib.streamingr.   r/   r0   r1   r2   r3   messages.messagestypes.beta.threadsr4   __all__r5   r6   rC   r   rF   r   r   r@   r>   <module>r     s   # " " " " " / / / / / / / / / /       % % % % % %  ! ! ! ! ! !                               A @ @ @ @ @ @ @ @ @ @ @ @ @         
 ' & & & & & & & ' ' ' ' ' ' ; ; ; ; ; ; ; ; Z Z Z Z Z Z Z Z . . . . . . . .                                    7 6 6 6 6 6 6 6 & & & & & &n
%\l \l \l \l \lo \l \l \l~^q ^q ^q ^q ^q# ^q ^q ^qB? ? ? ? ? ? ? ?:D D D D D D D D:E E E E E E E E:J J J J J J J J J Jr@   