
    -2iUB                       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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   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    g/var/www/html/pixcura-vrs/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)   >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_idr0   List[RunStepInclude] | Omitr1   Headers | Noner2   Query | Noner3   Body | Noner4   '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/r0   r1   r2   r3   r4   queryoptionscast_to)
ValueError_getr   r   r   StepRetrieveParamsr   	r&   r5   r7   r8   r0   r1   r2   r3   r4   s	            r'   retrievezSteps.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(+'%%y'&:<P<cdd     

 

 
	
r)   	afterbeforer0   limitorderr1   r2   r3   r4   rS   
str | OmitrT   rU   
int | OmitrV   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
        r@   rA   rC   rD   rE   rF   z/steps)rS   rT   r0   rU   rV   rH   )pagerK   model)rM   _get_api_listr   r   r   r   r   StepListParamsr&   r8   r7   rS   rT   r0   rU   rV   r1   r2   r3   r4   s               r'   listz
Steps.listd   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*   r5   r6   r7   r6   r8   r6   r0   r9   r1   r:   r2   r;   r3   r<   r4   r=   r!   r   )r8   r6   r7   r6   rS   rW   rT   rW   r0   r9   rU   rX   rV   rY   r1   r:   r2   r;   r3   r<   r4   r=   r!   rZ   __name__
__module____qualname__r   r(   r-   typing_extensions
deprecatedr   r   rQ   rb    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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!   AsyncStepsWithRawResponsec                     t          |           S r$   )rl   r%   s    r'   r(   zAsyncSteps.with_raw_response   s     )...r)   AsyncStepsWithStreamingResponsec                     t          |           S r,   )rn   r%   s    r'   r-   z"AsyncSteps.with_streaming_response   s     /t444r)   r.   Nr/   r5   r6   r7   r8   r0   r9   r1   r:   r2   r;   r3   r<   r4   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@   rA   rB   rC   rD   rE   rF   rG   r0   NrH   rJ   )rM   rN   r   r   r   rO   r   rP   s	            r'   rQ   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)   rR   rS   rW   rT   rU   rX   rV   rY   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\   )rM   r_   r   r   r   r   r   r`   ra   s               r'   rb   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!   rl   )r!   rn   rc   )r8   r6   r7   r6   rS   rW   rT   rW   r0   r9   rU   rX   rV   rY   r1   r:   r2   r;   r3   r<   r4   r=   r!   rq   rd   rj   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_wrapperrQ   rb   r&   rt   s     r'   __init__zStepsWithRawResponse.__init__S  sI     4  	 4
  				r)   Nrt   r   r!   ru   re   rf   rg   r{   rj   r)   r'   r"   r"   R  (        
 
 
 
 
 
r)   r"   c                      e Zd ZddZdS )rl   rt   r   r!   ru   c                    || _         t          j        |j                  | _        t          j        |j                  | _        d S rw   )rx   r   async_to_raw_response_wrapperrQ   rb   rz   s     r'   r{   z"AsyncStepsWithRawResponse.__init__c  sI     :  	 :
  				r)   Nrt   r   r!   ru   r}   rj   r)   r'   rl   rl   b  r~   r)   rl   c                      e Zd ZddZdS )r*   rt   r   r!   ru   c                x    || _         t          |j                  | _        t          |j                  | _        d S rw   )rx   r   rQ   rb   rz   s     r'   r{   z#StepsWithStreamingResponse.__init__s  sC     )  	 )
  				r)   Nr|   r}   rj   r)   r'   r*   r*   r  r~   r)   r*   c                      e Zd ZddZdS )rn   rt   r   r!   ru   c                x    || _         t          |j                  | _        t          |j                  | _        d S rw   )rx   r   rQ   rb   rz   s     r'   r{   z(AsyncStepsWithStreamingResponse.__init__  sC     /  	 /
  				r)   Nr   r}   rj   r)   r'   rn   rn     r~   r)   rn   )0
__future__r   rh   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   rj   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
!Y
 Y
 Y
 Y
 Y
O Y
 Y
 Y
xY
 Y
 Y
 Y
 Y
! Y
 Y
 Y
x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
r)   