
    2iB                       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/dS )    )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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dS )(r   4Build Assistants that can call models and use tools.returnStepsWithRawResponsec                     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
        )r#   selfs    o/root/.openclaw/workspace/.venv-openai/lib/python3.11/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responsezSteps.with_raw_response   s     $D)))    StepsWithStreamingResponsec                     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
        )r+   r&   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timeoutstep_idstr	thread_idrun_idr1   List[RunStepInclude] | Omitr2   Headers | Noner3   Query | Noner4   Body | Noner5   'float | httpx.Timeout | None | NotGivenr   c               .   |st          d|          |st          d|          |st          d|          ddi|pi }|                     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/r1   r2   r3   r4   r5   queryoptionscast_to)
ValueError_getr   r   r   StepRetrieveParamsr   	r'   r6   r8   r9   r1   r2   r3   r4   r5   s	            r(   retrievezSteps.retrieve0   s    F  	geXaeefff 	a_U[__``` 	caV]aabbb&QM<ORQyyA	AAAAAA(+'%%y'&:<P<cdd     

 

 
	
r*   	afterbeforer1   limitorderr2   r3   r4   r5   rT   
str | OmitrU   rV   
int | OmitrW   Literal['asc', 'desc'] | OmitSyncCursorPage[RunStep]c       
        ,   |st          d|          |st          d|          ddi|pi }|                     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
        rA   rB   rD   rE   rF   rG   z/steps)rT   rU   r1   rV   rW   rI   )pagerL   model)rN   _get_api_listr   r   r   r   r   StepListParamsr'   r9   r8   rT   rU   r1   rV   rW   r2   r3   r4   r5   s               r(   listz
Steps.listf   s    l  	geXaeefff 	a_U[__```&QM<ORQ!!7	77777((+'%%!&"(#*!&!&  %3	 	    ' " 
 
 	
r*   )r"   r#   )r"   r+   r6   r7   r8   r7   r9   r7   r1   r:   r2   r;   r3   r<   r4   r=   r5   r>   r"   r   )r9   r7   r8   r7   rT   rX   rU   rX   r1   r:   rV   rY   rW   rZ   r2   r;   r3   r<   r4   r=   r5   r>   r"   r[   __name__
__module____qualname____doc__r   r)   r.   typing_extensions
deprecatedr   r   rR   rc    r*   r(   r   r      s	       >>* * * _* 0 0 0 _0 "!"bcc 04 )-$("&;D3
 3
 3
 3
 3
 dc3
j "!"bcc !!/3 /3 )-$("&;DN
 N
 N
 N
 N
 dcN
 N
 N
r*   c                      e Zd 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dS )(r   r!   r"   AsyncStepsWithRawResponsec                     t          |           S r%   )rn   r&   s    r(   r)   zAsyncSteps.with_raw_response   s     )...r*   AsyncStepsWithStreamingResponsec                     t          |           S r-   )rp   r&   s    r(   r.   z"AsyncSteps.with_streaming_response   s     /t444r*   r/   Nr0   r6   r7   r8   r9   r1   r:   r2   r;   r3   r<   r4   r=   r5   r>   r   c               J  K   |st          d|          |st          d|          |st          d|          ddi|pi }|                     d| d| d| t          ||||t          d	|it          j                   d
{V           t                     d
{V S )r@   rA   rB   rC   rD   rE   rF   rG   rH   r1   NrI   rK   )rN   rO   r   r   r   rP   r   rQ   s	            r(   rR   zAsyncSteps.retrieve   s     F  	geXaeefff 	a_U[__``` 	caV]aabbb&QM<ORQYYA	AAAAAA(+'%19g2FH\Hopppppppp     

 

 

 

 

 

 

 

 
	
r*   rS   rT   rX   rU   rV   rY   rW   rZ   1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]c       
        ,   |st          d|          |st          d|          ddi|pi }|                     d| d| dt          t                   t	          ||	|
|t          |||||dt          j                  	          t          
          S r]   )rN   r`   r   r   r   r   r   ra   rb   s               r(   rc   zAsyncSteps.list  s    l  	geXaeefff 	a_U[__```&QM<ORQ!!7	77777 )(+'%%!&"(#*!&!&  %3	 	    ' " 
 
 	
r*   )r"   rn   )r"   rp   rd   )r9   r7   r8   r7   rT   rX   rU   rX   r1   r:   rV   rY   rW   rZ   r2   r;   r3   r<   r4   r=   r5   r>   r"   rs   re   rl   r*   r(   r   r      s	       >>/ / / _/ 5 5 5 _5 "!"bcc 04 )-$("&;D3
 3
 3
 3
 3
 dc3
j "!"bcc !!/3 /3 )-$("&;DN
 N
 N
 N
 N
 dcN
 N
 N
r*   c                      e Zd ZddZdS )r#   stepsr   r"   Nonec                    || _         t          j        |j                  | _        t          j        |j                  | _        d S N)_stepsr   to_raw_response_wrapperrR   rc   r'   rv   s     r(   __init__zStepsWithRawResponse.__init__W  sI     4  	 4
  				r*   Nrv   r   r"   rw   rf   rg   rh   r}   rl   r*   r(   r#   r#   V  (        
 
 
 
 
 
r*   r#   c                      e Zd ZddZdS )rn   rv   r   r"   rw   c                    || _         t          j        |j                  | _        t          j        |j                  | _        d S ry   )rz   r   async_to_raw_response_wrapperrR   rc   r|   s     r(   r}   z"AsyncStepsWithRawResponse.__init__g  sI     :  	 :
  				r*   Nrv   r   r"   rw   r   rl   r*   r(   rn   rn   f  r   r*   rn   c                      e Zd ZddZdS )r+   rv   r   r"   rw   c                x    || _         t          |j                  | _        t          |j                  | _        d S ry   )rz   r   rR   rc   r|   s     r(   r}   z#StepsWithStreamingResponse.__init__w  sC     )  	 )
  				r*   Nr~   r   rl   r*   r(   r+   r+   v  r   r*   r+   c                      e Zd ZddZdS )rp   rv   r   r"   rw   c                x    || _         t          |j                  | _        t          |j                  | _        d S ry   )rz   r   rR   rc   r|   s     r(   r}   z(AsyncStepsWithStreamingResponse.__init__  sC     /  	 /
  				r*   Nr   r   rl   r*   r(   rp   rp     r   r*   rp   )0
__future__r   rj   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#   rn   r+   rp   rl   r*   r(   <module>r      s{   # " " " " "           % % % % % %  " " " " " " M M M M M M M M M M M M M M M M M M > > > > > > > > ( ( ( ( ( ( < < < < < < < < [ [ [ [ [ [ [ [ ; ; ; ; ; ; ; ; B B B B B B B B O O O O O O O O 9 9 9 9 9 9 H H H H H HL
![
 [
 [
 [
 [
O [
 [
 [
|[
 [
 [
 [
 [
! [
 [
 [
|
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
r*   