
    2hB                    h   S SK Jr  S SKrS SKJr  S SKJr  S SKrSSKJr  SSK	J
r
JrJrJrJr  SSKJrJr  SS	KJr  SS
KJrJr  SSKJrJr  SSKJrJr  SSKJrJr  SSK J!r!J"r"  SSK#J$r$  SSK%J&r&  SS/r' " S S\5      r( " S S\5      r) " S S5      r* " S S5      r+ " S S5      r, " S S5      r-g)    )annotationsN)List)Literal   )_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S rSr\SS j5       r\SS j5       r\R                  " S5      \	SSS\	S.                 SS jj5       r
\R                  " S5      \	\	\	\	\	SSS\	S.	                       SS	 jj5       rS
rg)r      c                    [        U 5      $ z
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    `/var/www/auris/envauris/lib/python3.13/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responseSteps.with_raw_response   s     $D))    c                    [        U 5      $ 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_response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               *   U(       d  [        SU< 35      eU(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU SU 3[        UUUU[        S	U0[        R
                  5      S
9[        S9$ )  
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$   step_id	thread_idrun_idr0   r1   r2   r3   r4   s	            r%   retrieve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beforer0   limitorderr1   r2   r3   r4   c       
           U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU S3[        [           [	        UU	U
U[        UUUUUS.[        R                  5      S	9[        S
9$ 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
r7   r8   r:   r;   r<   r=   z/steps)rN   rO   r0   rP   rQ   r?   )pagerB   model)rD   _get_api_listr   r   r   r   r   StepListParamsr$   rJ   rI   rN   rO   r0   rP   rQ   r1   r2   r3   r4   s               r%   list
Steps.listd   s    l WXaWdeffTU[T^_``&QM<ORQ!!	{&7((+'%%!&"(#*!&!& %33	  ' " 
 	
r(    )returnr"   )r\   r+   rH   strrI   r^   rJ   r^   r0   List[RunStepInclude] | NotGivenr1   Headers | Noner2   Query | Noner3   Body | Noner4   'float | httpx.Timeout | None | NotGivenr\   r   )rJ   r^   rI   r^   rN   str | NotGivenrO   rd   r0   r_   rP   int | NotGivenrQ   !Literal['asc', 'desc'] | NotGivenr1   r`   r2   ra   r3   rb   r4   rc   r\   zSyncCursorPage[RunStep]__name__
__module____qualname____firstlineno__r   r&   r,   typing_extensions
deprecatedr   rK   rY   __static_attributes__r[   r(   r%   r   r      sy   * * 0 0 !!"bc 4= )-$("&;D3
3
 	3

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

 N
 N
 1N
 N
 1N
 &N
 "N
  N
 9N
  
!!N
 dN
r(   c                     \ rS rSr\SS j5       r\SS j5       r\R                  " S5      \	SSS\	S.                 SS jj5       r
\R                  " S5      \	\	\	\	\	SSS\	S.	                       SS	 jj5       rS
rg)r      c                    [        U 5      $ r!   )AsyncStepsWithRawResponser#   s    r%   r&   AsyncSteps.with_raw_response   s     )..r(   c                    [        U 5      $ r*   )AsyncStepsWithStreamingResponser#   s    r%   r,   "AsyncSteps.with_streaming_response   s     /t44r(   r.   Nr/   c               Z  #    U(       d  [        SU< 35      eU(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU SU 3[        UUUU[        S	U0[        R
                  5      I S
h  vN S9[        S9I S
h  vN $  N N7f)r6   r7   r8   r9   r:   r;   r<   r=   r>   r0   Nr?   rA   )rD   rE   r   r   r   rF   r   rG   s	            r%   rK   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$   BB+B'B+"B)#B+)B+rM   c       
           U(       d  [        SU< 35      eU(       d  [        SU< 35      eSS0U=(       d    0 EnU R                  SU SU S3[        [           [	        UU	U
U[        UUUUUS.[        R                  5      S	9[        S
9$ rS   )rD   rV   r   r   r   r   r   rW   rX   s               r%   rY   AsyncSteps.list   s    l WXaWdeffTU[T^_``&QM<ORQ!!	{&7 )(+'%%!&"(#*!&!& %33	  ' " 
 	
r(   r[   )r\   rr   )r\   ru   r]   )rJ   r^   rI   r^   rN   rd   rO   rd   r0   r_   rP   re   rQ   rf   r1   r`   r2   ra   r3   rb   r4   rc   r\   z1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]rg   r[   r(   r%   r   r      sy   / / 5 5 !!"bc 4= )-$("&;D3
3
 	3

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

 N
 N
 1N
 N
 1N
 &N
 "N
  N
 9N
  
;!N
 dN
r(   c                      \ rS rSrSS jrSrg)r"   iR  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g N)_stepsr   to_raw_response_wrapperrK   rY   r$   stepss     r%   __init__StepsWithRawResponse.__init__S  sC     44 	 44

 		r(   r~   rY   rK   Nr   r   r\   Nonerh   ri   rj   rk   r   rn   r[   r(   r%   r"   r"   R      
r(   r"   c                      \ rS rSrSS jrSrg)rr   ib  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g r}   )r~   r   async_to_raw_response_wrapperrK   rY   r   s     r%   r   "AsyncStepsWithRawResponse.__init__c  sC     :: 	 ::

 		r(   r   Nr   r   r\   r   r   r[   r(   r%   rr   rr   b  r   r(   rr   c                      \ rS rSrSS jrSrg)r+   ir  c                x    Xl         [        UR                  5      U l        [        UR                  5      U l        g r}   )r~   r   rK   rY   r   s     r%   r   #StepsWithStreamingResponse.__init__s  s7     ) 	 )

 		r(   r   Nr   r   r[   r(   r%   r+   r+   r  r   r(   r+   c                      \ rS rSrSS jrSrg)ru   i  c                x    Xl         [        UR                  5      U l        [        UR                  5      U l        g r}   )r~   r   rK   rY   r   s     r%   r   (AsyncStepsWithStreamingResponse.__init__  s7     / 	 /

 		r(   r   Nr   r   r[   r(   r%   ru   ru     r   r(   ru   ).
__future__r   rl   typingr   r   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"   rr   r+   ru   r[   r(   r%   <module>r      s    #   %  " A A > ( < [ ; B O 9 HL
!Y
O Y
xY
! Y
x
 
 
 
 
 
 
 
r(   