g~ddlmZddlZddlmZddlmZGddeZGddej Z ddZ ddZ dS)) annotationsN)Callable)overridec<eZdZdfd ZeddZeZxZS) CancelledErrormsgstrreturnNonecX||_t|dSN)rsuper__init__)selfr __class__s R/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/openai/cli/_progress.pyrzCancelledError.__init__ s( c|jSr )rrs r__str__zCancelledError.__str__ s xr)rr r r )r r )__name__ __module__ __qualname__rrr__repr__ __classcell__rs@rrrsXXHHHHHrrcDeZdZddfd Zdd ZedddZxZS) BufferReaderrNbufbytesdesc str | Noner r ct|t||_d|_t t|||_dS)Nr)r!)rrlen_len _progressprogress _callback)rrr!rs rrzBufferReader.__init__sM HH !#c((666rintc|jSr )r%rs r__len__zBufferReader.__len__s yrn int | Nonec"tj||}|xjt |z c_ ||jn5#t $r(}td||d}~wwxYw|S)NzThe upload was cancelled: {}) ioBytesIOreadr&r$r( Exceptionrformat)rr-chunkes rr2zBufferReader.reads a(( #e**$ R NN4> * * * * R R R !?!F!Fq!I!IJJPQ Q R sA B $#BB )rN)rr r!r"r r )r r))r,)r-r.r r )rrrrr+rr2rrs@rrrs{7777777     X     rrtotalfloatr!r"r Callable[[float], None]cPddl}|d|d fd }|S) NrT)r7 unit_scaler!r'r8r r cv|_|krdSdSr )r-closerefresh)r'meterr7s rincrzprogress..incr0s7 u   KKMMMMM MMOOOOOr)r'r8r r )tqdm)r7r!rAr@r?s` @rr'r'+sNKKK IIEdI > >E Krir)c&t|dzS)Ni)r))rBs rMBrD:s qG|  r)r7r8r!r"r r9)rBr)r r)) __future__rr0typingrtyping_extensionsrr3rr1rr'rDrrrIs"""""" &&&&&&     Y   2:.    r