
    h~                        S SK Jr  S SKrS SKJr  S SKJr   " S S\5      r " S S\R                  5      r
SS	 jrSS
 jrg)    )annotationsN)Callable)overridec                  D   ^  \ rS rSrSU 4S jjr\SS j5       r\rSrU =r	$ )CancelledError   c                0   > Xl         [        TU ]	  U5        g N)msgsuper__init__)selfr   	__class__s     F/var/www/html/env/lib/python3.13/site-packages/openai/cli/_progress.pyr   CancelledError.__init__	   s        c                    U R                   $ r
   r   r   s    r   __str__CancelledError.__str__   s    xxr   r   )r   strreturnNone)r   r   )
__name__
__module____qualname____firstlineno__r   r   r   __repr____static_attributes____classcell__r   s   @r   r   r      s#       Hr   r   c                  R   ^  \ rS rSrSSU 4S jjjrSS jr\S	S
S jj5       rSrU =r	$ )BufferReader   c                   > [         TU ]  U5        [        U5      U l        SU l        [        [        U5      US9U l        g )Nr   )desc)r   r   len_len	_progressprogress	_callback)r   bufr'   r   s      r   r   BufferReader.__init__   s4    H	!#c(6r   c                    U R                   $ r
   )r)   r   s    r   __len__BufferReader.__len__   s    yyr   c                   [         R                  R                  X5      nU =R                  [	        U5      -  sl         U R                  U R                  5        U$ ! [         a   n[        SR                  U5      5      UeS nAff = f)NzThe upload was cancelled: {})	ioBytesIOreadr*   r(   r,   	Exceptionr   format)r   nchunkes       r   r5   BufferReader.read   sq    

(#e*$	RNN4>>*   	R !?!F!Fq!IJPQQ	Rs   A 
B&BB)r,   r)   r*   )r   N)r-   bytesr'   
str | Noner   r   )r   int))r8   z
int | Noner   r<   )
r   r   r   r   r   r0   r   r5   r    r!   r"   s   @r   r$   r$      s&    7 7 	 	r   r$   c                F   ^ ^ SS K nUR                  T SUS9mSUU 4S jjnU$ )Nr   T)total
unit_scaler'   c                b   > U Tl         U T:X  a  TR                  5         g TR                  5         g r
   )r8   closerefresh)r+   meterrA   s    r   incrprogress.<locals>.incr0   s$    uKKMMMOr   )r+   floatr   r   )tqdm)rA   r'   rJ   rG   rF   s   `   @r   r+   r+   +   s+    IIEdI>E  Kr   c                    [        U S-  5      $ )Ni   )r>   )is    r   MBrM   :   s    qG|r   )rA   rI   r'   r=   r   zCallable[[float], None])rL   r>   r   r>   )
__future__r   r3   typingr   typing_extensionsr   r6   r   r4   r$   r+   rM    r   r   <module>rR      s7    " 	  &	Y 	2:: .r   