
    .hUB                    p   d dl mZ d dl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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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( ddgZ) G d de      Z* G d de      Z+ G d d      Z, G d d      Z- G d d      Z. G d d      Z/y)    )annotationsN)List)Literal   )_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)step_list_paramsstep_retrieve_params)RunStep)RunStepIncludeSteps
AsyncStepsc                     e Zd Zed	d       Zed
d       Z ej                  d      eddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd       Z
 ej                  d      eeeeeddde	d		 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd       Zy)r   c                    t        |       S a  
        This property can be used as a prefix for any HTTP method call to return
        the raw response object instead of the parsed content.

        For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers
        )StepsWithRawResponseselfs    i/var/www/html/axiom-chatbot/venv/lib/python3.12/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responsezSteps.with_raw_response   s     $D))    c                    t        |       S z
        An alternative to `.with_raw_response` that doesn't eagerly read the response body.

        For more information, see https://www.github.com/openai/openai-python#with_streaming_response
        )StepsWithStreamingResponser$   s    r&   with_streaming_responsezSteps.with_streaming_response%   s     *$//r(   >The Assistants API is deprecated in favor of the Responses APINincludeextra_headersextra_query
extra_bodytimeoutc                  |st        d|      |st        d|      |st        d|      ddi|xs i }| j                  d| d| d| t        ||||t        d	|it        j
                        
      t              S )  
        Retrieves a run step.

        Args:
          include: A list of additional fields to include in the response. Currently the only
              supported value is `step_details.tool_calls[*].file_search.results[*].content`
              to fetch the file search result content.

              See the
              [file search tool documentation](https://platform.openai.com/docs/assistants/tools/file-search#customizing-file-search-settings)
              for more information.

          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 5Expected a non-empty value for `run_id` but received 6Expected a non-empty value for `step_id` but received OpenAI-Betaassistants=v2	/threads//runs//steps/r/   r0   r1   r2   r3   queryoptionscast_to)
ValueError_getr   r   r   StepRetrieveParamsr   	r%   step_id	thread_idrun_idr/   r0   r1   r2   r3   s	            r&   retrievezSteps.retrieve.   s    F WXaWdeffTU[T^_``UV]U`abb&QM<ORQyy	{&yA(+'%%y'&:<P<c<cd   

 
	
r(   	afterbeforer/   limitorderr0   r1   r2   r3   c       
           |st        d|      |st        d|      ddi|xs i }| j                  d| d| dt        t           t	        ||	|
|t        |||||dt        j                        	      t        
      S a  
        Returns a list of run steps belonging to a run.

        Args:
          after: A cursor for use in pagination. `after` is an object ID that defines your place
              in the list. For instance, if you make a list request and receive 100 objects,
              ending with obj_foo, your subsequent call can include after=obj_foo in order to
              fetch the next page of the list.

          before: A cursor for use in pagination. `before` is an object ID that defines your place
              in the list. For instance, if you make a list request and receive 100 objects,
              starting with obj_foo, your subsequent call can include before=obj_foo in order
              to fetch the previous page of the list.

          include: A list of additional fields to include in the response. Currently the only
              supported value is `step_details.tool_calls[*].file_search.results[*].content`
              to fetch the file search result content.

              See the
              [file search tool documentation](https://platform.openai.com/docs/assistants/tools/file-search#customizing-file-search-settings)
              for more information.

          limit: A limit on the number of objects to be returned. Limit can range between 1 and
              100, and the default is 20.

          order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending
              order and `desc` for descending order.

          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
        r6   r7   r9   r:   r;   r<   z/steps)rL   rM   r/   rN   rO   r>   )pagerA   model)rC   _get_api_listr   r   r   r   r   StepListParamsr%   rI   rH   rL   rM   r/   rN   rO   r0   r1   r2   r3   s               r&   listz
Steps.listd   s    l WXaWdeffTU[T^_``&QM<ORQ!!	{&7((+'%%!&"(#*!&!& %33	  ' " 
 	
r(   )returnr#   )rX   r+   rG   strrH   rZ   rI   rZ   r/   List[RunStepInclude] | Omitr0   Headers | Noner1   Query | Noner2   Body | Noner3   'float | httpx.Timeout | None | NotGivenrX   r   )rI   rZ   rH   rZ   rL   
str | OmitrM   r`   r/   r[   rN   
int | OmitrO   Literal['asc', 'desc'] | Omitr0   r\   r1   r]   r2   r^   r3   r_   rX   zSyncCursorPage[RunStep]__name__
__module____qualname__r   r'   r,   typing_extensions
deprecatedr   r   rJ   rW    r(   r&   r   r      s   * * 0 0 "!!"bc 04 )-$("&;D3
3
 	3

 3
 -3
 &3
 "3
  3
 93
 
3
 d3
j "!!"bc !!/3 /3 )-$("&;DN
N
 	N

 N
 N
 -N
 N
 -N
 &N
 "N
  N
 9N
  
!!N
 dN
r(   c                     e Zd Zed	d       Zed
d       Z ej                  d      eddde	d	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd       Z
 ej                  d      eeeeeddde	d		 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd       Zy)r   c                    t        |       S r"   )AsyncStepsWithRawResponser$   s    r&   r'   zAsyncSteps.with_raw_response   s     )..r(   c                    t        |       S r*   )AsyncStepsWithStreamingResponser$   s    r&   r,   z"AsyncSteps.with_streaming_response   s     /t44r(   r-   Nr.   c               8  K   |st        d|      |st        d|      |st        d|      ddi|xs i }| j                  d| d| d| t        ||||t        d	|it        j
                         d
{         t               d
{   S 7 7 w)r5   r6   r7   r8   r9   r:   r;   r<   r=   r/   Nr>   r@   )rC   rD   r   r   r   rE   r   rF   s	            r&   rJ   zAsyncSteps.retrieve   s     F WXaWdeffTU[T^_``UV]U`abb&QM<ORQYY	{&yA(+'%19g2FH\HoHopp   

 

 
	
 q

s$   A8B:B;BBBBrK   c       
           |st        d|      |st        d|      ddi|xs i }| j                  d| d| dt        t           t	        ||	|
|t        |||||dt        j                        	      t        
      S rQ   )rC   rT   r   r   r   r   r   rU   rV   s               r&   rW   zAsyncSteps.list   s    l WXaWdeffTU[T^_``&QM<ORQ!!	{&7 )(+'%%!&"(#*!&!& %33	  ' " 
 	
r(   )rX   rl   )rX   rn   rY   )rI   rZ   rH   rZ   rL   r`   rM   r`   r/   r[   rN   ra   rO   rb   r0   r\   r1   r]   r2   r^   r3   r_   rX   z1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]rc   ri   r(   r&   r   r      s   / / 5 5 "!!"bc 04 )-$("&;D3
3
 	3

 3
 -3
 &3
 "3
  3
 93
 
3
 d3
j "!!"bc !!/3 /3 )-$("&;DN
N
 	N

 N
 N
 -N
 N
 -N
 &N
 "N
  N
 9N
  
;!N
 dN
r(   c                      e Zd ZddZy)r#   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y N)_stepsr   to_raw_response_wrapperrJ   rW   r%   stepss     r&   __init__zStepsWithRawResponse.__init__S  sE     44 	 44

 		r(   Nrw   r   rX   Nonerd   re   rf   rx   ri   r(   r&   r#   r#   R      
r(   r#   c                      e Zd ZddZy)rl   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y rs   )rt   r   async_to_raw_response_wrapperrJ   rW   rv   s     r&   rx   z"AsyncStepsWithRawResponse.__init__c  sE     :: 	 ::

 		r(   Nrw   r   rX   rz   r{   ri   r(   r&   rl   rl   b  r|   r(   rl   c                      e Zd ZddZy)r+   c                z    || _         t        |j                        | _        t        |j                        | _        y rs   )rt   r   rJ   rW   rv   s     r&   rx   z#StepsWithStreamingResponse.__init__s  s9     ) 	 )

 		r(   Nry   r{   ri   r(   r&   r+   r+   r  r|   r(   r+   c                      e Zd ZddZy)rn   c                z    || _         t        |j                        | _        t        |j                        | _        y rs   )rt   r   rJ   rW   rv   s     r&   rx   z(AsyncStepsWithStreamingResponse.__init__  s9     / 	 /

 		r(   Nr   r{   ri   r(   r&   rn   rn     r|   r(   rn   )0
__future__r   rg   typingr   r   httpx r   _typesr   r	   r
   r   r   r   r   _utilsr   r   _compatr   	_resourcer   r   	_responser   r   
paginationr   r   _base_clientr   r   types.beta.threads.runsr   r    types.beta.threads.runs.run_stepr   (types.beta.threads.runs.run_step_includer   __all__r   r   r#   rl   r+   rn   ri   r(   r&   <module>r      s    #   %  " M M M > ( < [ ; B O 9 HL
!Y
O Y
xY
! Y
x
 
 
 
 
 
 
 
r(   