
    
@g=                       d dl 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 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 )    )annotations)List)LiteralN   )_legacy_response)	NOT_GIVENBodyQueryHeadersNotGiven)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            
      r    e Zd Zed"d            Zed#d            Zedddedd$dZeeeeeddded	d%d!ZdS )&r   returnStepsWithRawResponsec                     t          |           S a  
        This property can be used as a prefix for any HTTP method call to return the
        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    \/var/www/piapp/venv/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'   Nincludeextra_headersextra_query
extra_bodytimeoutstep_idstr	thread_idrun_idr-   List[RunStepInclude] | NotGivenr.   Headers | Noner/   Query | Noner0   Body | Noner1   '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/r-   r.   r/   r0   r1   queryoptionscast_to)
ValueError_getr   r   r   StepRetrieveParamsr   	r$   r2   r4   r5   r-   r.   r/   r0   r1   s	            r%   retrievezSteps.retrieve0   s    D  	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beforer-   limitorderr.   r/   r0   r1   rP   str | NotGivenrQ   rR   int | NotGivenrS   !Literal['asc', 'desc'] | NotGiven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
        r=   r>   r@   rA   rB   rC   z/steps)rP   rQ   r-   rR   rS   rE   )pagerH   model)rJ   _get_api_listr   r   r   r   r   StepListParamsr$   r5   r4   rP   rQ   r-   rR   rS   r.   r/   r0   r1   s               r%   listz
Steps.liste   s    j  	geXaeefff 	a_U[__```&QM<ORQ!!7	77777((+'%%!&"(#*!&!&  %3	 	    ' " 
 
 	
r'   )r   r    )r   r(   r2   r3   r4   r3   r5   r3   r-   r6   r.   r7   r/   r8   r0   r9   r1   r:   r   r   )r5   r3   r4   r3   rP   rT   rQ   rT   r-   r6   rR   rU   rS   rV   r.   r7   r/   r8   r0   r9   r1   r:   r   rW   	__name__
__module____qualname__r   r&   r+   r   rN   r_    r'   r%   r   r      s        * * * _* 0 0 0 _0 4= )-$("&;D3
 3
 3
 3
 3
 3
t !*!*3< )3< )-$("&;DN
 N
 N
 N
 N
 N
 N
 N
r'   c            
      r    e Zd Zed"d            Zed#d            Zedddedd$dZeeeeeddded	d%d!ZdS )&r   r   AsyncStepsWithRawResponsec                     t          |           S r"   )rg   r#   s    r%   r&   zAsyncSteps.with_raw_response   s     )...r'   AsyncStepsWithStreamingResponsec                     t          |           S r*   )ri   r#   s    r%   r+   z"AsyncSteps.with_streaming_response   s     /t444r'   Nr,   r2   r3   r4   r5   r-   r6   r.   r7   r/   r8   r0   r9   r1   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<   r=   r>   r?   r@   rA   rB   rC   rD   r-   NrE   rG   )rJ   rK   r   r   r   rL   r   rM   s	            r%   rN   zAsyncSteps.retrieve   s     D  	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'   rO   rP   rT   rQ   rR   rU   rS   rV   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 rY   )rJ   r\   r   r   r   r   r   r]   r^   s               r%   r_   zAsyncSteps.list   s    j  	geXaeefff 	a_U[__```&QM<ORQ!!7	77777 )(+'%%!&"(#*!&!&  %3	 	    ' " 
 
 	
r'   )r   rg   )r   ri   r`   )r5   r3   r4   r3   rP   rT   rQ   rT   r-   r6   rR   rU   rS   rV   r.   r7   r/   r8   r0   r9   r1   r:   r   rl   ra   re   r'   r%   r   r      s        / / / _/ 5 5 5 _5 4= )-$("&;D3
 3
 3
 3
 3
 3
t !*!*3< )3< )-$("&;DN
 N
 N
 N
 N
 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_wrapperrN   r_   r$   ro   s     r%   __init__zStepsWithRawResponse.__init__Q  sA    (@N
 
 %<J
 
			r'   Nro   r   r   rp   rb   rc   rd   rv   re   r'   r%   r    r    P  (        
 
 
 
 
 
r'   r    c                      e Zd ZddZdS )rg   ro   r   r   rp   c                    || _         t          j        |j                  | _        t          j        |j                  | _        d S rr   )rs   r   async_to_raw_response_wrapperrN   r_   ru   s     r%   rv   z"AsyncStepsWithRawResponse.__init__]  sA    (FN
 
 %BJ
 
			r'   Nro   r   r   rp   rx   re   r'   r%   rg   rg   \  ry   r'   rg   c                      e Zd ZddZdS )r(   ro   r   r   rp   c                x    || _         t          |j                  | _        t          |j                  | _        d S rr   )rs   r   rN   r_   ru   s     r%   rv   z#StepsWithStreamingResponse.__init__i  s;    4N
 
 1J
 
			r'   Nrw   rx   re   r'   r%   r(   r(   h  ry   r'   r(   c                      e Zd ZddZdS )ri   ro   r   r   rp   c                x    || _         t          |j                  | _        t          |j                  | _        d S rr   )rs   r   rN   r_   ru   s     r%   rv   z(AsyncStepsWithStreamingResponse.__init__u  s;    :N
 
 7J
 
			r'   Nr}   rx   re   r'   r%   ri   ri   t  ry   r'   ri   ).
__future__r   typingr   typing_extensionsr   httpx r   _typesr   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    rg   r(   ri   re   r'   r%   <module>r      su   # " " " " "       % % % % % %  " " " " " " A A A A A A A A A A A A A A        ) ( ( ( ( ( < < < < < < < < [ [ [ [ [ [ [ [ ; ; ; ; ; ; ; ; 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
!W
 W
 W
 W
 W
O W
 W
 W
tW
 W
 W
 W
 W
! W
 W
 W
t	
 	
 	
 	
 	
 	
 	
 	
	
 	
 	
 	
 	
 	
 	
 	
	
 	
 	
 	
 	
 	
 	
 	
	
 	
 	
 	
 	
 	
 	
 	
 	
 	
r'   