
    _iUB                    p   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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)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                     \ 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    d/var/www/html/land-ocr/venv/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/r2   r3   r4   r5   r6   queryoptionscast_to)
ValueError_getr   r   r   StepRetrieveParamsr   	r&   step_id	thread_idrun_idr2   r3   r4   r5   r6   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beforer2   limitorderr3   r4   r5   r6   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
r9   r:   r<   r=   r>   r?   z/steps)rP   rQ   r2   rR   rS   rA   )pagerD   model)rF   _get_api_listr   r   r   r   r   StepListParamsr&   rL   rK   rP   rQ   r2   rR   rS   r3   r4   r5   r6   s               r'   list
Steps.listd   s    l WXaWdeffTU[T^_``&QM<ORQ!!	{&7((+'%%!&"(#*!&!& %33	  ' " 
 	
r*    )returnr$   )r^   r-   rJ   strrK   r`   rL   r`   r2   List[RunStepInclude] | Omitr3   Headers | Noner4   Query | Noner5   Body | Noner6   'float | httpx.Timeout | None | NotGivenr^   r   )rL   r`   rK   r`   rP   
str | OmitrQ   rf   r2   ra   rR   
int | OmitrS   Literal['asc', 'desc'] | Omitr3   rb   r4   rc   r5   rd   r6   re   r^   zSyncCursorPage[RunStep]__name__
__module____qualname____firstlineno__r   r(   r.   typing_extensions
deprecatedr   r   rM   r[   __static_attributes__r]   r*   r'   r   r      sy   * * 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                     \ 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*   r0   Nr1   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)r8   r9   r:   r;   r<   r=   r>   r?   r@   r2   NrA   rC   )rF   rG   r   r   r   rH   r   rI   s	            r'   rM   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+rO   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$ rU   )rF   rX   r   r   r   r   r   rY   rZ   s               r'   r[   AsyncSteps.list   s    l WXaWdeffTU[T^_``&QM<ORQ!!	{&7 )(+'%%!&"(#*!&!& %33	  ' " 
 	
r*   r]   )r^   rt   )r^   rw   r_   )rL   r`   rK   r`   rP   rf   rQ   rf   r2   ra   rR   rg   rS   rh   r3   rb   r4   rc   r5   rd   r6   re   r^   z1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]ri   r]   r*   r'   r   r      sy   / / 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                      \ 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_wrapperrM   r[   r&   stepss     r'   __init__StepsWithRawResponse.__init__S  sC     44 	 44

 		r*   r   r[   rM   Nr   r   r^   Nonerj   rk   rl   rm   r   rp   r]   r*   r'   r$   r$   R      
r*   r$   c                      \ rS rSrSS jrSrg)rt   ib  c                    Xl         [        R                  " UR                  5      U l        [        R                  " UR                  5      U l        g r   )r   r   async_to_raw_response_wrapperrM   r[   r   s     r'   r   "AsyncStepsWithRawResponse.__init__c  sC     :: 	 ::

 		r*   r   Nr   r   r^   r   r   r]   r*   r'   rt   rt   b  r   r*   rt   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   rM   r[   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)rw   i  c                x    Xl         [        UR                  5      U l        [        UR                  5      U l        g r   )r   r   rM   r[   r   s     r'   r   (AsyncStepsWithStreamingResponse.__init__  s7     / 	 /

 		r*   r   Nr   r   r]   r*   r'   rw   rw     r   r*   rw   )0
__future__r   rn   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$   rt   r-   rw   r]   r*   r'   <module>r      s    #   %  " M M M > ( < [ ; B O 9 HL
!Y
O Y
xY
! Y
x
 
 
 
 
 
 
 
r*   