
    OYhf/                    @   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 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 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'y)    )annotations)LiteralN   )_legacy_response)	NOT_GIVENBodyQueryHeadersNotGiven)maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)step_list_params)RunStepSteps
AsyncStepsc            	          e Zd Zedd       Zed	d       Zddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
dZeeeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZy)r   c                    t        |       S N)StepsWithRawResponseselfs    g/var/www/feuerwehr-webapp/venv/lib/python3.12/site-packages/openai/resources/beta/threads/runs/steps.pywith_raw_responsezSteps.with_raw_response   s    #D))    c                    t        |       S r   )StepsWithStreamingResponser   s    r    with_streaming_responsezSteps.with_streaming_response   s    )$//r"   Nextra_headersextra_query
extra_bodytimeoutc          	         |st        d|      |st        d|      |st        d|      ddi|xs i }| j                  d| d| d| t        ||||	      t        
      S )I  
        Retrieves a run step.

        Args:
          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&   optionscast_to
ValueError_getr   r   r   step_id	thread_idrun_idr'   r(   r)   r*   s           r    retrievezSteps.retrieve#   s    2 WXaWdeffTU[T^_``UV]U`abb&QM<ORQyy	{&yA(+Q[el   
 	
r"   afterbeforelimitorderr'   r(   r)   r*   c       	           |st        d|      |st        d|      ddi|xs i }| j                  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,
              ending with obj_foo, your subsequent call can include before=obj_foo in order to
              fetch the previous page of the list.

          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.   r0   r1   r2   r3   z/steps)rA   rB   rC   rD   )r'   r(   r)   r*   query)pager6   model)r9   _get_api_listr   r   r   r   r   StepListParamsr   r>   r=   rA   rB   rC   rD   r'   r(   r)   r*   s              r    listz
Steps.listK   s    X WXaWdeffTU[T^_``&QM<ORQ!!	{&7((+'%%!&"(!&!&	 %33 % " 
 	
r"   )returnr   )rN   r$   r<   strr=   rP   r>   rP   r'   Headers | Noner(   Query | Noner)   Body | Noner*   'float | httpx.Timeout | None | NotGivenrN   r   )r>   rP   r=   rP   rA   str | NotGivenrB   rU   rC   int | NotGivenrD   !Literal['asc', 'desc'] | NotGivenr'   rQ   r(   rR   r)   rS   r*   rT   rN   zSyncCursorPage[RunStep]	__name__
__module____qualname__r   r!   r%   r   r?   rM    r"   r    r   r      s#   * * 0 0 )-$("&;D&
&
 	&

 &
 &&
 "&
  &
 9&
 
&
Z !*!* )3< )-$("&;DD
D
 	D

 D
 D
 D
 1D
 &D
 "D
  D
 9D
 
!D
r"   c            	          e Zd Zedd       Zed	d       Zddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
dZeeeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 ddZy)r   c                    t        |       S r   )AsyncStepsWithRawResponser   s    r    r!   zAsyncSteps.with_raw_response   s    (..r"   c                    t        |       S r   )AsyncStepsWithStreamingResponser   s    r    r%   z"AsyncSteps.with_streaming_response   s    .t44r"   Nr&   c          	        K   |st        d|      |st        d|      |st        d|      ddi|xs i }| j                  d| d| d| t        ||||	      t        
       d{   S 7 w)r,   r-   r.   r/   r0   r1   r2   r3   r4   r&   r5   Nr8   r;   s           r    r?   zAsyncSteps.retrieve   s     2 WXaWdeffTU[T^_``UV]U`abb&QM<ORQYY	{&yA(+Q[el   
 
 	
 
s   A,A5.A3/A5r@   c       	           |st        d|      |st        d|      ddi|xs i }| j                  d| d| dt        t           t	        |||	|
t        ||||dt        j                        	      t        
      S rF   )r9   rJ   r   r   r   r   r   rK   rL   s              r    rM   zAsyncSteps.list   s    X WXaWdeffTU[T^_``&QM<ORQ!!	{&7 )(+'%%!&"(!&!&	 %33 % " 
 	
r"   )rN   r_   )rN   ra   rO   )r>   rP   r=   rP   rA   rU   rB   rU   rC   rV   rD   rW   r'   rQ   r(   rR   r)   rS   r*   rT   rN   z1AsyncPaginator[RunStep, AsyncCursorPage[RunStep]]rX   r\   r"   r    r   r      s#   / / 5 5 )-$("&;D&
&
 	&

 &
 &&
 "&
  &
 9&
 
&
Z !*!* )3< )-$("&;DD
D
 	D

 D
 D
 D
 1D
 &D
 "D
  D
 9D
 
;D
r"   c                      e Zd ZddZy)r   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y r   )_stepsr   to_raw_response_wrapperr?   rM   r   stepss     r    __init__zStepsWithRawResponse.__init__  s=    (@@NN
 %<<JJ
	r"   Nri   r   rN   NonerY   rZ   r[   rj   r\   r"   r    r   r   
      
r"   r   c                      e Zd ZddZy)r_   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y r   )rf   r   async_to_raw_response_wrapperr?   rM   rh   s     r    rj   z"AsyncStepsWithRawResponse.__init__  s=    (FFNN
 %BBJJ
	r"   Nri   r   rN   rl   rm   r\   r"   r    r_   r_     rn   r"   r_   c                      e Zd ZddZy)r$   c                z    || _         t        |j                        | _        t        |j                        | _        y r   )rf   r   r?   rM   rh   s     r    rj   z#StepsWithStreamingResponse.__init__#  s1    4NN
 1JJ
	r"   Nrk   rm   r\   r"   r    r$   r$   "  rn   r"   r$   c                      e Zd ZddZy)ra   c                z    || _         t        |j                        | _        t        |j                        | _        y r   )rf   r   r?   rM   rh   s     r    rj   z(AsyncStepsWithStreamingResponse.__init__/  s1    :NN
 7JJ
	r"   Nrr   rm   r\   r"   r    ra   ra   .  rn   r"   ra   )(
__future__r   typing_extensionsr   httpx r   _typesr   r   r	   r
   r   _utilsr   _compatr   	_resourcer   r   	_responser   r   
paginationr   r   _base_clientr   r   types.beta.threads.runsr    types.beta.threads.runs.run_stepr   __all__r   r   r   r_   r$   ra   r\   r"   r    <module>r      s    # %  " A A ' ( < [ ; : 9L
!u
O u
pu
! u
p	
 	
	
 	
	
 	
	
 	
r"   