
    =hm                       d dl mZ d dlZddlmZmZmZmZmZ ddl	m
Z
 ddlmZmZ ddlmZmZ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)    )annotationsN   )	NOT_GIVENBodyQueryHeadersNotGiven)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)make_request_options)ConcurrencyRetrieveResponseConcurrencyResourceAsyncConcurrencyResourcec                  V    e Zd Zedd       Zedd       Zddded	 	 	 	 	 	 	 	 	 ddZy)	r   c                    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/RetellAI/retell-python-sdk#accessing-raw-response-data-eg-headers
        )"ConcurrencyResourceWithRawResponseselfs    l/var/www/html/phonemate/phone_mate_backend/venv/lib/python3.12/site-packages/retell/resources/concurrency.pywith_raw_responsez%ConcurrencyResource.with_raw_response   s     2$77    c                    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/RetellAI/retell-python-sdk#with_streaming_response
        )(ConcurrencyResourceWithStreamingResponser   s    r   with_streaming_responsez+ConcurrencyResource.with_streaming_response!   s     8==r   Nextra_headersextra_query
extra_bodytimeoutc          	     L    | j                  dt        ||||      t              S )<Get the current concurrency and concurrency limit of the org/get-concurrencyr"   optionscast_to_getr   r   r   r#   r$   r%   r&   s        r   retrievezConcurrencyResource.retrieve*   s5     yy(+Q[el 0  
 	
r   )returnr   )r1   r    
r#   zHeaders | Noner$   zQuery | Noner%   zBody | Noner&   z'float | httpx.Timeout | None | NotGivenr1   r   __name__
__module____qualname__r
   r   r!   r   r0    r   r   r   r      sm    8 8 > > )-$("&;D

 &
 "
  
 9
 
%
r   c                  V    e Zd Zedd       Zedd       Zddded	 	 	 	 	 	 	 	 	 ddZy)	r   c                    t        |       S r   )'AsyncConcurrencyResourceWithRawResponser   s    r   r   z*AsyncConcurrencyResource.with_raw_response?   s     7t<<r   c                    t        |       S r   )-AsyncConcurrencyResourceWithStreamingResponser   s    r   r!   z0AsyncConcurrencyResource.with_streaming_responseI   s     =TBBr   Nr"   c          	     h   K   | j                  dt        ||||      t               d{   S 7 w)r(   r)   r"   r*   Nr-   r/   s        r   r0   z!AsyncConcurrencyResource.retrieveR   sC      YY(+Q[el 0  
 
 	
 
s   )202)r1   r:   )r1   r<   r2   r3   r7   r   r   r   r   >   so    = = C C )-$("&;D

 &
 "
  
 9
 
%
r   c                      e Zd ZddZy)r   c                F    || _         t        |j                        | _        y N)_concurrencyr   r0   r   concurrencys     r   __init__z+ConcurrencyResourceWithRawResponse.__init__g   s    '/  
r   NrC   r   r1   Noner4   r5   r6   rD   r7   r   r   r   r   f       
r   r   c                      e Zd ZddZy)r:   c                F    || _         t        |j                        | _        y r@   )rA   r   r0   rB   s     r   rD   z0AsyncConcurrencyResourceWithRawResponse.__init__p   s    '5  
r   NrC   r   r1   rF   rG   r7   r   r   r:   r:   o   rH   r   r:   c                      e Zd ZddZy)r    c                F    || _         t        |j                        | _        y r@   )rA   r   r0   rB   s     r   rD   z1ConcurrencyResourceWithStreamingResponse.__init__y   s    '4  
r   NrE   rG   r7   r   r   r    r    x   rH   r   r    c                      e Zd ZddZy)r<   c                F    || _         t        |j                        | _        y r@   )rA   r   r0   rB   s     r   rD   z6AsyncConcurrencyResourceWithStreamingResponse.__init__   s    ':  
r   NrK   rG   r7   r   r   r<   r<      rH   r   r<   )
__future__r   httpx_typesr   r   r   r   r	   _compatr
   	_resourcer   r   	_responser   r   r   r   _base_clientr   #types.concurrency_retrieve_responser   __all__r   r   r   r:   r    r<   r7   r   r   <module>rY      sy    #  > > % 9  0 M "<
=%
/ %
P%
/ %
P
 

 

 

 
r   