h+ ddlZddlZddlZddlZddlmZmZddlmZddl m Z m Z ddl m Z ddlmZmZddlmZddlmZdd lmZdd lmZmZdd lmZmZmZdd lmZdd lmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ej`dk\rddlm1Z1nddl2m1Z1ej`dk\rddlm3Z3nddl2m3Z3ddl4m5Z5m6Z6ddl7m8Z8m9Z9m:Z:m;Z;ddlm?Z?ddl@mAZAddlBmCZCddlDmEZEddlFmGZGddlHmIZImJZJddlKmLZLmMZMe(deNZOe.dZPe geQfZRej\de+eZSGd d!eZT dd)e/e*ePe%ePfd*eUd+e)eQd,eNd-eVd.e)e8d/eVd0e)e geQfd1eQd2eGd3eGd4eGd5eGd6eQd7eVd8eVd9e%ePf"d:ZWGd;de!eSe$eSZYd?d"dd#dd$d%d&d'd(d#d@ dAed+eNd*eUd-eVd.e)e8d/eVd0e)e geQfd1eQd2eGd3eGd4eGd5eGd7eVd9e!efdBZZej ddd?d"dd#dd$d%d&d'd(d#dC dAe/eUdDe\fdEe/e1dFe1dGfdHeNdIe)eUdJe)eUdKe)eUd+e)eNd*eUd-eVd.e)e8d/eVd0e)e geQfd1eQd2eGd3eGd4eGd5eGd7eVd9e!e+f&dLZ]ej ddd?d"dd#dd$d%d&d'd(d#dC dAe/eUdDe\fdEe1dMdHeNdIe)eUdJe)eUdKe)eUd+e)eNd*eUd-eVd.e)e8d/eVd0e)e geQfd1eQd2eGd3eGd4eGd5eGd7eVd9e!ef&dNZ] ddd?d"dd#dd$d%d&d'd(d#dC dAe/eUdDe\fdEe/e1dMe1dFe1dGfdHeNdIe)eUdJe)eUdKe)eUd+e)eNd*eUd-eVd.e)e8d/eVd0e)e geQfd1eQd2eGd3eGd4eGd5eGd7eVd9e/e!ee!e+ff&dOZ]GdPdQeZ^GdRdSe^Z_GdTdUe^Z`GdVdWe^ZaGdXdYe^ZbGdZd[e^ZcGd\d]eaZdGd^d_e^ZeGd`dae^ZfGdbdce^ZgGdddee^ZhGdfdge^ZiGdhdie^ZjGdjdke'Zke GdldmZlGdndoe?Zmendpk(rhddloZoddlpZpddqlqmrZrddrlsmtZtddslumvZvddtlHmJZJevdudvd"wZueJdxdydzZHeHjd{d|d}d~erddeHdddddeuetdg ZxddlymzZzezexZ{e8d"Z7eme`gemjece7d#d5Z}e}jddZe}jddZe}jddZe}jsxe}jede}jedepjdeoj dddkre}j ee{e}jsxdddyy#1swYyxYw)N)ABCabstractmethoddeque) dataclassfield) timedelta) RawIOBaseUnsupportedOperation)ceil)mmap) length_hint)PathLikestat)EventRLockThread) TracebackType)AnyBinaryIOCallableContextManagerDequeDictGenericIterableList NamedTupleNewTypeOptionalSequenceTextIOTupleTypeTypeVarUnion))Literal)r' )Self)filesize get_console)ConsoleGroup JustifyMethodRenderableType) Highlighter) JupyterMixin)Live) ProgressBar)Spinner) StyleType)ColumnTable)TextTextTypeTaskID ProgressType_IcpeZdZdZdddddeffd Zdd Zdd Zd ee e d ee dee dd fdZ xZ S) _TrackThreadz)A thread to periodically update progress.progressProgresstask_idr= update_periodc|||_||_||_t|_d|_t |dy)NrT)daemon)rBrDrErdone completedsuper__init__)selfrBrDrE __class__s W/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/pip/_vendor/rich/progress.pyrKz_TrackThread.__init__Gs9   *G  %returnNc|j}|jj}|j}d}|jj }||sh|jj jrH|j}||k7r||||z |}||s!|jj jrH|jj|j|jdy)NrT)rIrefresh) rDrBadvancerErHwaitlive is_startedrIupdate)rLrDrSrElast_completedrTrIs rNrunz_TrackThread.runPs,,--''** yy~~}%$--*<*<*G*GI*^!; ?@UW  NN --'   * 5 d ;   !-3H  >> #' "        s0ABB8B9B= BBB Bc eZdZdZ d)dedddededdf d Zd*d Zd e e e d e e d e e ddfdZ defdZdefdZedefdZdefdZdefdZedefdZedefdZdefdZdefdZdefdZd+dedefdZdeeee ffdZ!d+dedefdZ"d+dede#efdZ$d,d Z%d-d!ed"edefd#Z&defd$Z'd%e(defd&Z)d'e*e(ddfd(Z+y)._Readerz9A reader that tracks progress while it's being read from.handlerBrCtask close_handlerPNcJ||_||_||_||_d|_yNF)rrBrr_closed)rLrrBrrs rNrKz_Reader.__init__s(    ( rOc:|jj|Sr[)rr_r^s rNr_z_Reader.__enter__s  rOrarbrcc$|jyr[)closergs rNrhz_Reader.__exit__s rOc|Sr[r^s rN__iter__z_Reader.__iter__s rOct|j}|jj|jt ||SNrS)nextrrBrSrlen)rLlines rN__next__z_Reader.__next__s4DKK  diiT; rOc|jSr[)rr^s rNclosedz_Reader.closeds ||rOc6|jjSr[)rfilenor^s rNrz_Reader.fileno{{!!##rOc6|jjSr[)risattyr^s rNrz_Reader.isattyrrOc.|jjSr[)rmoder^s rNrz _Reader.mode{{rOc.|jjSr[)rnamer^s rNrz _Reader.namerrOc6|jjSr[)rreadabler^s rNrz_Reader.readable{{##%%rOc6|jjSr[)rseekabler^s rNrz_Reader.seekablerrOcyrrr^s rNwritablez_Reader.writablesrOsizec|jj|}|jj|jt ||Sr)rreadrBrSrr)rLrblocks rNrz _Reader.reads:   & diiU< rObc|jj|}|jj|j||Sr)rreadintorBrSr)rLrns rNrz_Reader.readintos6 KK  # dii3rOc|jj|}|jj|jt ||Sr)rreadlinerBrSrr)rLrrs rNrz_Reader.readlines:{{##D) diiT; rOhintc |jj|}|jj|jt t t||Sr)r readlinesrBrSrsummapr)rLrliness rNrz_Reader.readlinessA %%d+ diiSe_1EF rOc^|jr|jjd|_y)NT)rrrrr^s rNrz _Reader.close s"    KK    rOoffsetwhencec|jj||}|jj|j||S)NrI)rseekrBrWr)rLrrposs rNrz _Reader.seeks8kkvv. TYY#6 rOc6|jjSr[)rtellr^s rNrz _Reader.tells{{!!rOsctd)Nwriter )rLrs rNrz _Reader.writes "7++rOrctd)N writelinesr)rLrs rNrz_Reader.writeliness "<00rO)T)rPr)ri)r),rjrkrlrmrr=boolrKr_r r$rorrhrbytesrpropertyrintrrstrrrrrrrr& bytearray memoryviewr rrrrrrrrrrrrrOrNrrsC"        4 ./-('   (% $$$$ c   c  &$&&$&$e % :t ;< S% c4;  3C "c",s,s,1 1$1rOrc`eZdZdZdddeddfdZdefdZd eee d ee d ee ddfd Z y) _ReadContextzEA utility class to handle a context for both a reader and a progress.rBrCreaderrPNc ||_||_yr[)rBr)rLrBrs rNrKz_ReadContext.__init__"s    rOcj|jj|jjSr[)rBr]rr_r^s rNr_z_ReadContext.__enter__&s% {{$$&&rOrarbrccr|jj|jj|||yr[)rBstoprrhrgs rNrhz_ReadContext.__exit__*s*  Xw7rO) rjrkrlrmr?rKr_r r$rorrhrrOrNrrsjO!!R!D!'2'84 ./8-(8' 8  8rOr Reading...) rxrzr{r|r}r~rrrrrfilec |r tdgng} | jt|| | | tt ft | |||||xsd| d}|j |||}t||S)aRead bytes from a file while tracking progress. Args: file (Union[str, PathLike[str], BinaryIO]): The path to the file to read, or a file-like object in binary mode. total (int): Total number of bytes to read. description (str, optional): Description of task show next to progress bar. Defaults to "Reading". auto_refresh (bool, optional): Automatic refresh, disable to force a refresh after each iteration. Default is True. transient: (bool, optional): Clear the progress on exit. Defaults to False. console (Console, optional): Console to write to. Default creates internal Console instance. refresh_per_second (float): Number of times per second to refresh the progress information. Defaults to 10. style (StyleType, optional): Style for the bar background. Defaults to "bar.back". complete_style (StyleType, optional): Style for the completed bar. Defaults to "bar.complete". finished_style (StyleType, optional): Style for a finished bar. Defaults to "bar.finished". pulse_style (StyleType, optional): Style for pulsing bars. Defaults to "bar.pulse". disable (bool, optional): Disable display of progress. Returns: ContextManager[BinaryIO]: A context manager yielding a progress reader. rrrrr)ryrx)rrrDownloadColumnrrC wrap_filer)rryrxrzr{r|r}r~rrrrrrrBrs rNrr4sJEP> ?@UW  NN --'      !   !-3H  E{  KF & ))rO) ryrxrzr{r|r}r~rrrrr PathLike[str]rrtr bufferingencodingerrorsnewlinec yr[rrrrrrrryrxrzr{r|r}r~rrrrrs rNopenru, rOrbc yr[rrs rNrrrrOc |r tdgng}|jt| |||tt ft ||| | | | xsd|d}|j ||||||||}t||S)aRead bytes from a file while tracking progress. Args: path (Union[str, PathLike[str], BinaryIO]): The path to the file to read, or a file-like object in binary mode. mode (str): The mode to use to open the file. Only supports "r", "rb" or "rt". buffering (int): The buffering strategy to use, see :func:`io.open`. encoding (str, optional): The encoding to use when reading in text mode, see :func:`io.open`. errors (str, optional): The error handling strategy for decoding errors, see :func:`io.open`. newline (str, optional): The strategy for handling newlines in text mode, see :func:`io.open` total: (int, optional): Total number of bytes to read. Must be provided if reading from a file handle. Default for a path is os.stat(file).st_size. description (str, optional): Description of task show next to progress bar. Defaults to "Reading". auto_refresh (bool, optional): Automatic refresh, disable to force a refresh after each iteration. Default is True. transient: (bool, optional): Clear the progress on exit. Defaults to False. console (Console, optional): Console to write to. Default creates internal Console instance. refresh_per_second (float): Number of times per second to refresh the progress information. Defaults to 10. style (StyleType, optional): Style for the bar background. Defaults to "bar.back". complete_style (StyleType, optional): Style for the completed bar. Defaults to "bar.complete". finished_style (StyleType, optional): Style for a finished bar. Defaults to "bar.finished". pulse_style (StyleType, optional): Style for pulsing bars. Defaults to "bar.pulse". disable (bool, optional): Disable display of progress. encoding (str, optional): The encoding to use when reading in text mode. Returns: ContextManager[BinaryIO]: A context manager yielding a progress reader. rrrrr)rrrrrryrx)rrrrrrCrr)rrrrrrryrxrzr{r|r}r~rrrrrrrBrs rNrrsbEP> ?@UW  NN --'      !   !-3H]]  F & ))rOcteZdZUdZdZeeed<d deeddfdZ defdZ dd de fd Z e dd de fd Zy) ProgressColumnz3Base class for a widget to use in progress display.N max_refresh table_columnrPc.||_i|_d|_yr[) _table_column_renderable_cache _update_time)rLrs rNrKzProgressColumn.__init__s)MO-1rOc2|jxs tS)z.Get a table column, used to build tasks table.)rr9r^s rNget_table_columnzProgressColumn.get_table_columns!!-VX-rOrTaskc.|j}|j=|js1 |j|j\}}||jz|kDr|S|j |}||f|j|j<|S#t $rY9wxYw)aCalled by the Progress object to return a renderable for the given task. Args: task (Task): An object containing information regarding the task. Returns: RenderableType: Anything renderable (including str). )r}rrIridKeyErrorrender)rLr current_time timestamp renderables rN__call__zProgressColumn.__call__ s}}    ' &(,(>(>tww(G% :t///,>%%[[& +7*Dtww'  sB BBcy)z"Should return a renderable object.NrrLrs rNrzProgressColumn.render"srOr[)rjrkrlrmrr rn__annotations__r9rKrr2r rrrrOrNrrsl=#'K%'2Xf%522 .&.V.161n11rOrcLeZdZdZ d dddedeeffdZddd efd ZxZ S) RenderableColumnzA column to insert an arbitrary column. Args: renderable (RenderableType, optional): Any renderable. Defaults to empty string. Nrr rc4||_t| |yNr)r rJrK)rLr rrMs rNrKzRenderableColumn.__init__.s% l3rOrrrPc|jSr[)r rs rNrzRenderableColumn.render4s rO)) rjrkrlrmr2r r9rKrrprqs@rNrr'sB,.4SW4(4@H@P4 6nrOrc eZdZdZ ddedeedededee f fd Z dded eeded dfd Z d d d e fdZ xZS) SpinnerColumnaA column with a 'spinner' animation. Args: spinner_name (str, optional): Name of spinner animation. Defaults to "dots". style (StyleType, optional): Style of spinner. Defaults to "progress.spinner". speed (float, optional): Speed factor of spinner. Defaults to 1.0. finished_text (TextType, optional): Text used when task is finished. Defaults to " ". N spinner_namerspeed finished_textrct||||_t|trt j |n||_t|!|y)Nrrr) r7spinner isinstancerr; from_markuprrJrK)rLrrrrrrMs rNrKzSpinnerColumn.__init__BsN|5F --   ] +  l3rO spinner_stylerPc*t||||_y)a-Set a new spinner. Args: spinner_name (str): Spinner name, see python -m rich.spinner. spinner_style (Optional[StyleType], optional): Spinner style. Defaults to "progress.spinner". speed (float, optional): Speed factor of spinner. Defaults to 1.0. rN)r7r)rLrr!rs rN set_spinnerzSpinnerColumn.set_spinnerRs|=N rOrrc|jr|j}|S|jj|j }|Sr[)finishedrrrr})rLrtexts rNrzSpinnerColumn.renderasH}}     $$T]]_5  rO)dotsprogress.spinner? N)r(r))rjrkrlrmrr r8rnr<r9rKr#r2rrprqs@rNrr8s#%7"%)- 44 "4 4  4 v& 4&.@ O O * O O  O6nrOrcheZdZdZ ddededededee dee d dffd Z d d d e fd Z xZS)rzA column containing text.N text_formatrjustifymarkup highlighterrrPc||_||_||_||_||_t ||xs tdy)NTno_wrapr)r,r-rr.r/rJrKr9)rLr,rr-r.r/rrMs rNrKzTextColumn.__init__msD'&-   & l&JfT6JKrOrrcB|jj|}|jr-tj||j |j }n"t||j |j }|jr|jj||SNr)rr-) r,formatr.r;r rr-r/ highlight)rLr_textr&s rNrzTextColumn.render}sv  ''T'2 ;;##ET\\RDTZZFD       & &t , rO)noneleftTNN)rjrkrlrmrr8r1rr r3r9rKr;rrprqs@rNrrjs# "!'-1)-LLL L  L k* Lv&L L 6drOrcjeZdZdZ ddeedededededeed dffd Zd d d e fd Z xZ S)raRenders a visual progress bar. Args: bar_width (Optional[int], optional): Width of bar or None for full width. Defaults to 40. style (StyleType, optional): Style for the bar background. Defaults to "bar.back". complete_style (StyleType, optional): Style for the completed bar. Defaults to "bar.complete". finished_style (StyleType, optional): Style for a finished bar. Defaults to "bar.finished". pulse_style (StyleType, optional): Style for pulsing bars. Defaults to "bar.pulse". N bar_widthrrrrrrPcl||_||_||_||_||_t ||yr)r<rrrrrJrK)rLr<rrrrrrMs rNrKzBarColumn.__init__s;# ,,& l3rOrrc \t|jtd|jndtd|j|jdntd|j|j |j |j|j|j|j S)z&Gets a progress bar widget for a task.Nrr,) ryrIwidthpulseanimation_timerrrr) r6rymaxrIr<startedr}rrrrrs rNrzBarColumn.renders(, (>#a$D!T^^,..0$c!T^^6Lll"==?**....((  rO)(rsrtrurvN) rjrkrlrmr rr8r9rKr6rrprqs@rNrrs$&%$2$2!,)-4C=44" 4 " 4  4v&4 4  6  k  rOrc eZdZdZdddefdZy)TimeElapsedColumnzRenders time elapsed.rrrPc|jr |jn |j}| tddSt t dt |}tt|dS)zShow time elapsed.-:--:--progress.elapsedrr)seconds)r% finished_timeelapsedr;r rBrr)rLrrMdeltas rNrzTimeElapsedColumn.rendersS(, $$$4<< ? );< <#aW"67CJ&899rONrjrkrlrmr;rrrOrNrFrFs:6:d:rOrFceZdZdZ ddedededededee d ee d ed dffd Z e d ee d efdZddd efdZxZS)raShow task progress as a percentage. Args: text_format (str, optional): Format for percentage display. Defaults to "[progress.percentage]{task.percentage:>3.0f}%". text_format_no_percentage (str, optional): Format if percentage is unknown. Defaults to "". style (StyleType, optional): Style of output. Defaults to "none". justify (JustifyMethod, optional): Text justification. Defaults to "left". markup (bool, optional): Enable markup. Defaults to True. highlighter (Optional[Highlighter], optional): Highlighter to apply to output. Defaults to None. table_column (Optional[Column], optional): Table Column to use. Defaults to None. show_speed (bool, optional): Show speed if total is unknown. Defaults to False. Nr,text_format_no_percentagerr-r.r/rrrPc L||_||_t | ||||||y)N)r,rr-r.r/r)rQrrJrK) rLr,rQrr-r.r/rrrMs rNrKzTaskProgressColumn.__init__s9*C&$ ##%  rOrc| tddStjt|gdd\}}||z }t|d|ddS)zRender the speed in iterations per second. Args: task (Task): A Task object. Returns: Text: Text object containing the task speed. rzprogress.percentagerJ)ru×10³u×10⁶u×10⁹u×10¹²z.1fz it/s)r;r-pick_unit_and_suffixr)clsrunitsuffix data_speeds rN render_speedzTaskProgressColumn.render_speeds_ ="78 844 J <  f T\ z#&vhe43.0f}%rr9r:TNNF)rjrkrlrmrr8r1rr r3r9rK classmethodrnr;rZrrprqs@rNrrs K)+!!'-1)-   $'       k* v&    ,S%STSS& 6 d rOrcReZdZdZdZ d dededeeffd Zddd e fd Z xZ S) raRenders estimated time remaining. Args: compact (bool, optional): Render MM:SS when time remaining is less than an hour. Defaults to False. elapsed_when_finished (bool, optional): Render time elapsed when the task is finished. Defaults to False. ?compactrrcB||_||_t| |yr)r`rrJrK)rLr`rrrMs rNrKzTimeRemainingColumn.__init__s$  %:" l3rOrrrPc|jr|jr|j}d}n|j}d}|j t d|S|!t |j rd|Sd|Stt|d\}}t|d\}}|j r |s |dd |d}n |d d |dd |d}t ||S) zShow time remaining.rIzprogress.remainingrrJz--:--rH<02d:d) rr%rLtime_remainingryr;r`divmodr)rLr task_timerminutesrKhours formatteds rNrzTimeRemainingColumn.renders  % %$--**I&E++I(E :: %( (  4<<eL LYeL L"#i."5,w <<"3-q 6I )1WSM73-@IIU++rO)FFN) rjrkrlrmrrr r9rKr;rrprqs@rNrrsSK&+)- 44 $4v& 4,6,d,rOrc eZdZdZdddefdZy)FileSizeColumnzRenders completed filesize.rrrPcltjt|j}t |dS)Show data completed.zprogress.filesizerJ)r-decimalrrIr;rLr data_sizes rNrzFileSizeColumn.render9s)$$S%89 I%899rONrOrrOrNrnrn6s%:6:d:rOrnc eZdZdZdddefdZy)TotalFileSizeColumnzRenders total filesize.rrrPc|j(tjt|jnd}t |dS)rprzprogress.filesize.totalrJ)ryr-rqrr;rrs rNrzTotalFileSizeColumn.renderBs49=9OH$$S_5UW I%>??rONrOrrOrNruru?s!@6@d@rOrucDeZdZdZd dedeeffd ZdddefdZ xZ S) MofNCompleteColumnaHRenders completed count/total, e.g. ' 10/1000'. Best for bounded tasks with int quantities. Space pads the completed count so that progress length does not change as task progresses past powers of 10. Args: separator (str, optional): Text to separate completed and total values. Defaults to "/". separatorrc4||_t| |yr)ryrJrK)rLryrrMs rNrKzMofNCompleteColumn.__init__Ts" l3rOrrrPct|j}|jt|jnd}tt |}t ||d|j |dS)zShow completed/total.?rfprogress.downloadrJ)rrIryrrr;ry)rLrrIry total_widths rNrzMofNCompleteColumn.renderXsc' #'::#9DJJs#e*o +a((8 @%  rO)/N) rjrkrlrmrr r9rKr;rrprqs@rNrxrxHs3 4#48F;K4 6 d rOrxcJeZdZdZ d dedeeddffd Zdddefd Z xZ S) rzRenders file size downloaded and total, e.g. '0.5/2.3 GB'. Args: binary_units (bool, optional): Use binary units, KiB, MiB etc. Defaults to False. N binary_unitsrrPc4||_t| |yr)rrJrK)rLrrrMs rNrKzDownloadColumn.__init__js) l3rOrrct|j}|jt|jn|}|jrt j |gdd\}}nt j |gdd\}}|dk(rdnd}||z }|d|d}|j#t|j} | |z } | d|d} nd } |d | d |} t | d } | S)z.Calculate common unit for completed and total.) rKiBMiBGiBTiBPiBEiBZiBYiBi) rkBMBGBTBPBEBZBYBrTr,rz,.fr|rr*r}rJ)rrIryrr-rUr;)rLrrI unit_and_suffix_calculation_baserWrX precisioncompleted_ratio completed_strry total_ratio total_strdownload_status download_texts rNrzDownloadColumn.renderps'  $zz5C O9 )   #880QLD& $880ILD& A #d**2i[/: :: ! OE$,K&r)Ao6II*O1YKqA_4GH rO)FN) rjrkrlrmrr r9rKr;rrprqs@rNrrcsDLP4 48@8H4 4 !6!d!rOrc eZdZdZdddefdZy)TransferSpeedColumnz&Renders human readable transfer speed.rrrPc|jxs |j}| tddStjt |}t|ddS)zShow data transfer speed.r|zprogress.data.speedrJz/s)r\rr;r-rqr)rLrrrYs rNrzTransferSpeedColumn.rendersR##1tzz =#89 9%%c%j1 zl"%-BCCrONrOrrOrNrrs0D6DdDrOrc(eZdZUdZeed< eed<y)ProgressSamplez$Sample of progress for a given time.r rIN)rjrkrlrmrnrrrOrNrrs.$rOrceZdZUdZeed< eed< eeed< eed< e ed< dZ eeed< d Z e ed < e e Zeeefed < e dd d Zeeed< e dd d Zeeed< dZeeed< e dd d Zeeed<e d eZeed< defdZede fdZedeefdZedeefdZede fdZedefdZ edeefdZ!edeefdZ"d!d Z#y)"rzInformation regarding a progress task. This object should be considered read-only outside of the :class:`~Progress` class. rrxryrI _get_timeNrLTvisible)default_factoryfieldsF)defaultinitrepr start_time stop_timer\ctdS)NrT)maxlenrrrOrNz Task.s T 2rO)rrr _progress)rr_lockrPc"|jS)z(float: Get the current time, in seconds.)rr^s rNr}z Task.get_times~~rOc|jduS)z#bool: Check if the task as started.N)rr^s rNrCz Task.startedsd**rOcN|jy|j|jz S)zPOptional[float]: Get the number of steps remaining, if a non-None total was set.NryrIr^s rN remainingzTask.remainings$ :: zzDNN**rOc|jy|j|j|jz S|j|jz S)z]Optional[float]: Time elapsed since task was started, or ``None`` if the task hasn't started.N)rrr}r^s rNrMz Task.elapsedsC ?? " >> %>>DOO3 3}}00rOc|jduS)zCheck if the task has finished.N)rLr^s rNr%z Task.finisheds!!--rOc|jsy|j|jz dz}tdtd|}|S)zOfloat: Get progress of task as a percentage. If a None total was set, returns 0Y@)ryrIminrB)rLrIs rN percentagezTask.percentages>zz^^djj0E9 s3 23 rOcJ|jy|j5|j}|s dddy|dj|djz }|dk(r dddyt |}t |t d|D}||z }|cdddS#1swYyxYw)z=Optional[float]: Get the estimated speed in steps per second.Nrrc34K|]}|jywr[r).0samples rN zTask.speed..s!Ov&"2"2!O)rrrr iterrr)rLrB total_time iter_progresstotal_completedrs rNrz Task.speeds ?? " ZZ ~~H  ""//(1+2G2GGJQ  !NM  !!O!OOO#j0E   sB%B!.BB"cx|jry|j}|sy|j}|yt||z }|S)zJOptional[float]: Get estimated time to completion, or ``None`` if no data.rN)r%rrr )rLrrestimates rNrgzTask.time_remainingsC == NN   E)*rOcT|jjd|_d|_y)zReset progress.N)rclearrLr\r^s rN_resetz Task._reset s" !"rOri)$rjrkrlrmr=rrr rnGetTimeCallablerLrrrdictrrrrrr\rrrrrr}rrCrrMr%rrrgrrrOrNrrs JG' E?>*+%)M8E?)(GTJ"48FDcN8?"'5u"MJMN!&t%e!LIxLN&*NHUO*>',2U(Iu^$eU;E5; % ++++8E?++ 1%11.$..Ex"   #rOrceZdZdZddddddddddd deeefd eed e d e d e d e de de dee de de ddfdZ e deedffdZedefdZedeefdZedeefdZede fdZdOdZdOdZdefdZdeeedeed eeddfd!Z dPd#ee e!e"e!fd$ee d%e#d&eed'ed(e de e!fd)Z$ dQdd*d+d,e%d$ee#d&eed'ede%f d-Z&e'jP dRddd*d.d,eed/e)fd0e*d1d2e#d3eed4eed5eed$ee#d&eed'ede%fd6Z+e'jP dRddd*d.d,eed/e)fd0ee*d7e*d8fd2e#d3eed4eed5eed$ee#d&eed'ede,fd9Z+ dSddd*d.d,eed/e)fd0ee*d1e*d8e*d7fd2e#d3eed4eed5eed$ee#d&eed'edee%e,ffd:Z+d&eddfd;Z-d&eddfd<Z.ddddddd=d&ed$ee d%ee d>ee d'eed?ee d@e dAe/ddfdBZ0ddd"dddCd&edDe d$ee d%e#d?ee d'eedAe/ddfdEZ1dTd&ed>e ddfdFZ2dOdGZ3de4fdHZ5de e4fdIZ6dJe ede7fdKZ8de4fdLZ9 dUd'edDe d$ee d%e#d?e dAe/defdMZ:d&eddfdNZ;y)VrCaRenders an auto-updating progress bar(s). Args: console (Console, optional): Optional Console instance. Defaults to an internal Console instance writing to stdout. auto_refresh (bool, optional): Enable auto refresh. If disabled, you will need to call `refresh()`. refresh_per_second (Optional[float], optional): Number of times per second to refresh the progress information or None to use default (10). Defaults to None. speed_estimate_period: (float, optional): Period (in seconds) used to calculate the speed estimate. Defaults to 30. transient: (bool, optional): Clear the progress on exit. Defaults to False. redirect_stdout: (bool, optional): Enable redirection of stdout, so ``print`` may be used. Defaults to True. redirect_stderr: (bool, optional): Enable redirection of stderr. Defaults to True. get_time: (Callable, optional): A callable that gets the current time, or None to use Console.get_time. Defaults to None. disable (bool, optional): Disable progress display. Defaults to False expand (bool, optional): Expand tasks table to fit width. Defaults to False. NTrrg>@F) r{rzr~speed_estimate_periodr|redirect_stdoutredirect_stderrr}rexpandrr{rzr~rr|rrr}rrrPc |dkDsJdt|_| xs|j|_||_| |_| |_i|_td|_ t|xs t||||||j|_ |xs|jj|_|jj |_|jj"|_y)Nrzrefresh_per_second must be > 0)r{rzr~r|rrget_renderable)rrget_default_columnsrrrr_tasksr= _task_indexr5r.rrUr{r}printlog) rLr{rzr~rr|rrr}rrrs rNrKzProgress.__init__7s"A%G'GG%W <$":":"< %:"  *, #)!9,{}%1++..  !9DLL$9$9 \\'' <<##rO.cPtdtttfS)aGet the default columns used for a new Progress instance: - a text column for the description (TextColumn) - the bar itself (BarColumn) - a text column showing completion percentage (TextColumn) - an estimated-time-remaining column (TimeRemainingColumn) If the Progress instance is created without passing a columns argument, the default columns defined here will be used. You can also create a Progress instance using custom columns before and/or after the defaults, as in this example: progress = Progress( SpinnerColumn(), *Progress.get_default_columns(), "Elapsed:", TimeElapsedColumn(), ) This code shows the creation of a Progress display, containing a spinner to the left, the default columns, and a labeled elapsed time column. r)rrrr)rVs rNrzProgress.get_default_columns[s(2 A B K   !   rOc.|jjSr[)rUr{r^s rNr{zProgress.consolezsyy   rOc|j5t|jjcdddS#1swYyxYw)zGet a list of Task instances.N)rlistrvaluesr^s rNtaskszProgress.tasks~s5ZZ . **,- . . . #:Ac|j5t|jjcdddS#1swYyxYw)zA list of task IDs.N)rrrkeysr^s rNtask_idszProgress.task_idss5ZZ , ((*+ , , ,rc|j5|js dddytd|jjDcdddS#1swYyxYw)z'Check if all tasks have been completed.NTc34K|]}|jywr[)r%)rrs rNrz$Progress.finished..sFt}}Fr)rrallrr^s rNr%zProgress.finishedsWZZ G;; G GF1C1C1EFF G G GsA)AA cV|js|jjdyy)zStart the progress display.T)rRN)rrUr]r^s rNr]zProgress.starts || IIOODO )rOc|jj|jjs2|jjs|jj yyy)zStop the progress display.N)rUrr{is_interactive is_jupyterrr^s rNrz Progress.stopsB ||**4<<3J3J LL   4K*rOc&|j|Sr[r\r^s rNr_zProgress.__enter__r`rOrarbrcc$|jyr[)rrgs rNrhzProgress.__exit__s rOrrwryrIrDrxrEc#K|tt|xsd}||j|||}n|j||||jj r8t |||5}|D]}||xjdz c_ dddy|j} |j} |D]}|| |d| y#1swYyxYww)aTrack progress by iterating over a sequence. Args: sequence (Sequence[ProgressType]): A sequence of values you want to iterate over and track progress. total: (float, optional): Total number of steps. Default is len(sequence). completed (int, optional): Number of steps completed so far. Defaults to 0. task_id: (TaskID): Task to track. Default is new task. description: (str, optional): Description of task, if new task is created. update_period (float, optional): Minimum time (in seconds) between calls to update(). Defaults to 0.1. Returns: Iterable[ProgressType]: An iterable of values taken from the provided sequence. Nrr,) rnradd_taskrWrUrzrArIrSrR) rLrwryrIrDrxrE track_threadvaluerSrRs rNrzProgress.tracks, =+h/08DE ?mmKu mRG KKu K B 99 ! !dG]; 0|%0EK **a/*0 0 0 llGllG!  #   0 0sA)C+!C  =C CCr)rDrxrcd}||}n0|.|j5|j|j}ddd| td||j ||}n|j ||t |||dS#1swYNxYw)ajTrack progress file reading from a binary file. Args: file (BinaryIO): A file-like object opened in binary mode. total (int, optional): Total number of bytes to read. This must be provided unless a task with a total is also given. task_id (TaskID): Task to track. Default is new task. description (str, optional): Description of task, if new task is created. Returns: BinaryIO: A readable file-like object in binary mode. Raises: ValueError: When no total value can be extracted from the arguments or the task. Nz?unable to get the total number of bytes, please specify 'total'ryFr)rrry ValueErrorrrWr)rLrryrDrx total_bytess rNrzProgress.wrap_files.(,  K   9"kk'288  9  Q  ?mmK{mCG KK{K 3tT7?? 9 9s A==B)ryrDrxrrrrrrrcyr[r rLrrrrrrryrDrxs rNrz Progress.open rOrrcyr[rrs rNrz Progress.openrrOcdjt|d} | dvrtd||dk(} | dk(r"|dk(rtjdt d }n| d vr|d k(r td |dk(rd }|t |j}||j| | }n|j|| tj|d|} t| ||d} |dvrtj| |||| S| S)a#Track progress while reading from a binary file. Args: path (Union[str, PathLike[str]]): The path to the file to read. mode (str): The mode to use to open the file. Only supports "r", "rb" or "rt". buffering (int): The buffering strategy to use, see :func:`io.open`. encoding (str, optional): The encoding to use when reading in text mode, see :func:`io.open`. errors (str, optional): The error handling strategy for decoding errors, see :func:`io.open`. newline (str, optional): The strategy for handling newlines in text mode, see :func:`io.open`. total (int, optional): Total number of bytes to read. If none given, os.stat(path).st_size is used. task_id (TaskID): Task to track. Default is new task. description (str, optional): Description of task, if new task is created. Returns: BinaryIO: A readable file-like object in binary mode. Raises: ValueError: When an invalid mode is given. rF)reverse)brrrz invalid mode r,rzaline buffering (buffering=1) isn't supported in binary mode, the default buffer size will be usedr)rrrzcan't have unbuffered text I/Orr)rTr)rr)rrrline_buffering)rfsortedrwarningswarnRuntimeWarningrst_sizerrWiorr TextIOWrapper)rLrrrrrrryrDrx_moderrrs rNrz Progress.opens#BtU34 ) )}TH56 6#a D=Y!^ MMs I k !A~ !ABBa  =J&&E ?mmKum=G KKuK -ty9wTB ; ##!-   rOc|j5|j|}|j|j|_dddy#1swYyxYw)zStart a task. Starts a task (used when calculating elapsed time). You may need to call this manually, if you called ``add_task`` with ``start=False``. Args: task_id (TaskID): ID of task. N)rrrr})rLrDrs rN start_taskzProgress.start_taskksEZZ 2;;w'D&"&--/ 2 2 2s 1AAc|j5|j|}|j}|j||_||_dddy#1swYyxYw)zStop a task. This will freeze the elapsed time on the task. Args: task_id (TaskID): ID of task. N)rrr}rr)rLrDrr s rN stop_taskzProgress.stop_taskysQZZ *;;w'D==?L&".)DN  * * *s :AA)ryrIrSrxrrRrSrrRrc <|j5|j|} | j} |&|| jk7r|| _| j || xj|z c_||| _||| _||| _| jj|| j| z } |j} | |jz } | j}|j}|r.|dj| kr||r|dj| kr| dkDr|jt| | | j6| j| jk\r| j | j"| _ddd|r|j%yy#1swYxYw)aUpdate information associated with a task. Args: task_id (TaskID): Task id (returned by add_task). total (float, optional): Updates task.total if not None. completed (float, optional): Updates task.completed if not None. advance (float, optional): Add a value to task.completed if not None. description (str, optional): Change task description if not None. visible (bool, optional): Set visible flag if not None. refresh (bool): Force a refresh of progress information. Default is False. **fields (Any): Additional data fields required for rendering. Nr)rrrIryrrxrrrWr}rrpopleftr appendrrLrMrR)rLrDryrIrSrxrrRrrcompleted_startupdate_completedr old_sample_timerr s rNrWzProgress.updatesy0ZZ 2;;w'D"nnO Udjj%8"  "')$!*&#. "& KK  v &#~~? ==?L*T-G-GGOI''G ! 6 6 H  ! 6 6 H!#   >N!OP &NNdjj0&&.%)\\"A 2D  LLN E 2 2sDFA"FF)r]ryrIrrxr]c >|j}|j5|j|} | j|r|nd| _||| _|| _||| _|r|| _||| _ d| _ ddd|jy#1swYxYw)aReset a task so completed is 0 and the clock is reset. Args: task_id (TaskID): ID of task. start (bool, optional): Start the task after reset. Defaults to True. total (float, optional): New total steps in task, or None to use current total. Defaults to None. completed (int, optional): Number of steps completed. Defaults to 0. visible (bool, optional): Enable display of the task. Defaults to True. description (str, optional): Change task description if not None. Defaults to None. **fields (str): Additional data fields required for rendering. N) r}rrrrryrIrrrxrLrR) rLrDr]ryrIrrxrr rs rNresetzProgress.resets,}} ZZ &;;w'D KKM.3lDO " &DN"& $ &#. !%D  &  & &s ABBc|j}|j5|j|}|j}|xj|z c_|j|z }||jz }|j }|j } |r.|dj|kr| |r|dj|krt|dkDr| t|dkDr|jt|||jG|j|jk\r.|j"|j|_ |j|_dddy#1swYyxYw)zAdvance task by a number of steps. Args: task_id (TaskID): ID of task. advance (float): Number of steps to advance. Default is 1. rrTN)r}rrrIrrr r rr rryrLrMrr\) rLrDrSr rr rrrr s rNrSzProgress.advances%}} ZZ 1;;w'D"nnO NNg %N#~~? *T-G-GGOI''G ! 6 6 H  ! 6 6 Hi.4' i.4'   ^L:JK L &NNdjj0&&.%)\\"&*jj#) 1 1 1sBE4#EA.EEc|js2|jjr|jjyyy)z*Refresh (render) the progress information.N)rrUrVrRr^s rNrRzProgress.refresh s,|| 4 4 II   !5|rOc2t|j}|S)z*Get a renderable for the progress display.)r0get_renderables)rLr s rNrzProgress.get_renderablesD0023 rOc#JK|j|j}|yw)z5Get a number of renderables for the progress display.N)make_tasks_tabler)rLtables rNrzProgress.get_renderabless%%djj1 s!#rcd|jD}tj|d|jd}|D]1js|j fd|jD3|S)zGet a table to render the Progress display. Args: tasks (Iterable[Task]): An iterable of Task instances, one per row of the table. Returns: Table: A table instance. c3K|]>}t|tr tdn|jj @yw)Tr1N)rrr9rcopy)r_columns rNrz,Progress.make_tasks_table.."sE gs+t$--/4467 sAA)rr,)paddingrc3rK|].}t|tr|jn|0yw)r5N)rrr6)rcolumnrs rNrz,Progress.make_tasks_table../s> # *&#6#MMtM4!'.s47)rr:gridrradd_row)rLr table_columnsrrs @rNrzProgress.make_tasks_tablesn  <<   M6$++N D||  '+ll    rOcf|j5|jcdddS#1swYyxYw)z+Makes the Progress class itself renderable.N)rrr^s rN__rich__zProgress.__rich__:s* ZZ )&&( ) ) )s'0c |j5t|j||||||j|j}||j|j<|r|j |j|j}t t|jdz|_ddd|jS#1swYxYw)aAdd a new 'task' to the Progress display. Args: description (str): A description of the task. start (bool, optional): Start the task immediately (to calculate elapsed time). If set to False, you will need to call `start` manually. Defaults to True. total (float, optional): Number of total steps in the progress if known. Set to None to render a pulsing animation. Defaults to 100. completed (int, optional): Number of steps completed so far. Defaults to 0. visible (bool, optional): Enable display of the task. Defaults to True. **fields (str): Additional data fields required for rendering. Returns: TaskID: An ID you can use when calling `update`. )rrrrr,N) rrrr}rrr=rrR) rLrxr]ryrIrrrnew_task_indexs rNrzProgress.add_task?s0ZZ A  --jj D-1DKK(( ) 0 01!--N%c$*:*:&;a&?@D  A # A As BCC c`|j5|j|=dddy#1swYyxYw)z]Delete a task if it exists. Args: task_id (TaskID): A task ID. N)rr)rLrDs rN remove_taskzProgress.remove_taskjs,ZZ % G$ % % %s$-ri)NrN Working...皙?r[rNNNrrNNN)r,)TrrT)r!rrrrtypingoverloadrr)rr"rr rrWrrSrRr2rrr:rr$rr(rrOrNrCrC's $&*!$&'+ $ $.2"$^+,"$'""$ "$ " "$ % "$"$"$"$?+"$"$"$ "$H E.#*=$>  <!!!.tDz.. ,$v,,, G$GG* ! 44 ./-('   "&$('").0FFG)) ) &! )  )) , )\ $(@ %)' (@(@}(@ &! (@  (@ (@T __ "& $!%   $$('  C%/0  dm    3-    #  }  &!          __ "& $!%   $$('  C%/0  GCL'$-/0    3-    #  }  &!         $CF"& $!%K $$('KC%/0KGDM74='#,>?K K 3- K  K#K}K&!KK x KZ 2& 2T 2 * *D *&"&%)#'%)"&;; ; E? ; % ;c];$;;; ;B!%"&%)%% %  %  %$%c]%% %N1v11d1<  .!9 htnB).)!& ))) )  )  )) )V%6%d%rOrC__main__)Panel)Rule)Syntax)r:a~def loop_last(values: Iterable[T]) -> Iterable[Tuple[bool, T]]: """Iterate and generate a tuple with a flag for last value.""" iter_values = iter(values) try: previous_value = next(iter_values) except StopIteration: return for value in iter_values: yield False, previous_value previous_value = value yield True, previous_valuepython) line_numbersfoobarbaz123z:Text may be printed while the progress bars are rendering.z(In fact, [i]any[/i] renderable will workzSuch as [magenta]tables[/]...zPretty printed structures...examplezPretty printed)typer&z Syntax...zGive it a try!)cycle)record)r{r|z[red]DownloadingrTrz[green]Processingz[yellow]Thinkingr_rg333333?g{Gz?d)r)NrTNFNrrrsrtrurvr*FTr+r,)rsysr-rabcrr collectionsr dataclassesrrdatetimer r r mathr r operatorrosrr threadingrrrtypesrrrrrrrrrrrrr r!r"r#r$r%r& version_infor)pip._vendor.typing_extensionsr+rr-r.r{r/r0r1r2r/r3jupyterr4rUr5 progress_barr6rr7rr8rr9r:r&r;r<rr=r>rnrr?rArrrrrrr.rrrrrrrrFrrrnrurxrrrrrCrjrandomtimepanelr0ruler1syntaxr2r!progress_renderables itertoolsr=examplesrrBrtask1task2task3r%rWsleeprandintrrrrOrNr[s{  #(. ***v5w2#BB$!% 3 ~& 2u9%V^^D&(+%6%T$!!%.2 "! . .(!I H\*H\,BBCI I  E?I  I  I g  I I xE *+I I  I I I I I I !I "l#I Xd1id1N8>"%wr{82$!%.2 "! . .(>* >* >* >*  >* g  >*>*xE *+>*>* >*>*>*>*>*H>*B" !   #!%.2 "! . .(' _e+ ,  ws|+ ,  sm  SM  c]   C=   g   xE *+    ! "# $% &' (F)  0" !   #!%.2 "! . .(' _e+ , $-  sm  SM  c]   C=   g   xE *+    ! "# $% &' (H)  4?B" ! S* #!%.2 "! . .('S* _e+ ,S*  wt}gcl: ;S*S*sm S* SM S* c] S* C=S*S*S*g S*S*xE *+S*S* S* !S*"#S*$%S*&'S*( >( #^F%; ;<)S*l'1S'1T~"/N/d<' ' T : :EEP-,.-,`:^:@.@  6.^.b D. D%Z% z#z# z#zK %|K %\ z  " F % &E MM#sC  E 89' &$45   )*HT"G    % % '     - !!"4D!A!!"5T!B!!"4D!A## OOE3O / OOE3O / DJJt v~~a%) T(^, ##--]\--s B>U''U0