Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pip/_vendor/rich/__pycache__/progress.cpython-39.pyc
Ðазад
a "�h�� � @ s6 d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZ d dl m Z m Z d dl m Z d dl mZmZ d dlmZ d dlmZ d d lmZ d d lmZmZ d d lmZmZmZ d d l m Z d d lm 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-m.Z.m/Z/ ej0dk�r&d dlm1Z1 n d dl2m1Z1 ej0dk�rLd dlm3Z3 n d dl2m3Z3 ddl4m5Z5m6Z6 ddl7m8Z8m9Z9m:Z:m;Z; ddl<m=Z= ddl>m?Z? ddl@mAZA ddlBmCZC ddlDmEZE ddlFmGZG ddlHmIZImJZJ dd lKmLZLmMZM e(d eN�ZOe.d �ZPe g eQf ZRe�.d e+e �ZSG d d!� d!e�ZTd�e/e*eP e%eP f eUe)eQ eNeVe)e8 eVe)e g eQf eQeGeGeGeGeQeVeVe%eP d+�d,d-�ZWG d.d/� d/ee �ZXG d0d1� d1e!eS e$eS �ZYd2d#dd$dd%d&d'd(d)d$d3� e eNeUeVe)e8 eVe)e g eQf eQeGeGeGeGeVe!e d4�d5d6�ZZej[d�dd2d#dd$dd%d&d'd(d)d$d8� e/eUd9e\f e/e1d: e1d; f eNe)eU e)eU e)eU e)eN eUeVe)e8 eVe)e g eQf eQeGeGeGeGeVe!e+ d<�d=d>��Z]ej[d�dd2d#dd$dd%d&d'd(d)d$d8� e/eUd9e\f e1d? eNe)eU e)eU e)eU e)eN eUeVe)e8 eVe)e g eQf eQeGeGeGeGeVe!e d<�d@d>��Z]d�dd2d#dd$dd%d&d'd(d)d$d8� e/eUd9e\f e/e1d? e1d: e1d; f eNe)eU e)eU e)eU e)eN eUeVe)e8 eVe)e g eQf eQeGeGeGeGeVe/e!e e!e+ f d<�dAd>�Z]G dBdC� dCe�Z^G dDdE� dEe^�Z_G dFdG� dGe^�Z`G dHdI� dIe^�ZaG dJdK� dKe^�ZbG dLdM� dMe^�ZcG dNdO� dOea�ZdG dPdQ� dQe^�ZeG dRdS� dSe^�ZfG dTdU� dUe^�ZgG dVdW� dWe^�ZhG dXdY� dYe^�ZiG dZd[� d[e^�ZjG d\d]� d]e'�Zke G d^d_� d_��ZlG d`da� dae?�Zmendbk�r2d dloZod dlpZpddclqmrZr dddlsmtZt ddelumvZv ddflHmJZJ evdgdhd#di�ZueJdjdkdl�ZHeH�wdmdndo� dperdq�dreHdsdtdudv�dweuetdx�g Zxd dylymzZz ezex�Z{e8d#dz�Z7eme`� gem�|� �ec� �R e7d$d{����Z}e}j~d|d}d~�Ze}j~dd}d~�Z�e}j~d�dd~�Z�e}j��se}j�ed�d�� e}j�e�d�d�� ep��d�� eo��d d��dk �r�e}��e�e{�� �q�W d � n1 �s(0 Y dS )�� N)�ABC�abstractmethod��deque)� dataclass�field)� timedelta)� RawIOBase�UnsupportedOperation)�ceil)�mmap)� length_hint)�PathLike�stat)�Event�RLock�Thread)� TracebackType)�Any�BinaryIO�Callable�ContextManager�Deque�Dict�Generic�Iterable�List� NamedTuple�NewType�Optional�Sequence�TextIO�Tuple�Type�TypeVar�Union)� � )�Literal)r& � )�Self� )�filesize� get_console)�Console�Group� JustifyMethod�RenderableType)� Highlighter)� JupyterMixin)�Live)� ProgressBar)�Spinner)� StyleType)�Column�Table)�Text�TextType�TaskID� ProgressType�_Ic sj e Zd ZdZdded�� fdd� Zdd�d d �Zd d�d d �Zee e ee ee dd �dd�Z � Z S )� _TrackThreadz)A thread to periodically update progress.�Progressr< )�progress�task_id� update_periodc s2 || _ || _|| _t� | _d| _t� jdd� d S )Nr T)�daemon)rA rB rC r �done� completed�super�__init__)�selfrA rB rC �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pip/_vendor/rich/progress.pyrH G s z_TrackThread.__init__N��returnc C sn | j }| jj}| j}d}| jj}||�sT| jjjrT| j}||kr |||| � |}q | jj | j | jdd� d S )Nr T)rF �refresh) rB rA �advancerC rE �wait�live� is_startedrF �update)rI rB rQ rC �last_completedrR rF rL rL rM �runP s z_TrackThread.runc C s | � � | S �N��start�rI rL rL rM � __enter__^ s z_TrackThread.__enter__��exc_type�exc_val�exc_tbrO c C s | j �� | �� d S rX )rE �set�join�rI r^ r_ r` rL rL rM �__exit__b s z_TrackThread.__exit__)�__name__� __module__� __qualname__�__doc__�floatrH rW r\ r r# � BaseExceptionr rd � __classcell__rL rL rJ rM r? D s �r? � Working...TF� �bar.back� bar.complete� bar.finished� bar.pulse皙�����?)�sequence� description�totalrF � auto_refresh�console� transient�get_time�refresh_per_second�style�complete_style�finished_style� pulse_stylerC �disable� show_speedrO c c s� |rt d�gng }|�t| | | | d�t|d�tdd�f� t||||||pLd|d��}|�* |j| |||| d�E d H W d � n1 s�0 Y d S ) a= Track progress by iterating over a sequence. Args: sequence (Iterable[ProgressType]): A sequence (must support "len") you wish to iterate over. description (str, optional): Description of task show next to progress bar. Defaults to "Working". total: (float, optional): Total number of steps. Default is len(sequence). completed (int, optional): Number of steps completed so far. Defaults to 0. 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". update_period (float, optional): Minimum time (in seconds) between calls to update(). Defaults to 0.1. disable (bool, optional): Disable display of progress. show_speed (bool, optional): Show speed if total isn't known. Defaults to True. Returns: Iterable[ProgressType]: An iterable of the values in the sequence. �([progress.description]{task.description}�r{ r| r} r~ )r� T)�elapsed_when_finishedrm �rv rw rx ry rz r )ru rF rt rC N)� TextColumn�extend� BarColumn�TaskProgressColumn�TimeRemainingColumnr@ �track)rs rt ru rF rv rw rx ry rz r{ r| r} r~ rC r r� �columnsrA rL rL rM r� l s< *���� � �r� c @ s� e Zd ZdZd<edeedd�dd�Zd d�d d �Ze e e e e e e dd �d d �Z ed�dd�Zed�dd�Zeed�dd��Zed�dd�Zed�dd�Zeed�dd��Zeed�dd��Zed�d d �Zed�d d �Zed�d d!�Zd=eed#�d$d%�Z e e e e f d&�d'd(�Z!d>eed#�d)d*�Z"d?ee#e d+�d,d-�Z$dd�d.d/�Z%d@eeed1�d2d3�Z&ed�d4d5�Z'e(ed6�d7d8�Z)e*e( dd9�d:d;�Z+dS )A�_Readerz9A reader that tracks progress while it's being read from.Tr@ N)�handlerA �task� close_handlerO c C s" || _ || _|| _|| _d| _d S �NF)r� rA r� r� �_closed)rI r� rA r� r� rL rL rM rH � s z_Reader.__init__rN c C s | j �� | S rX )r� r\ r[ rL rL rM r\ � s z_Reader.__enter__r] c C s | � � d S rX )�closerc rL rL rM rd � s z_Reader.__exit__c C s | S rX rL r[ rL rL rM �__iter__� s z_Reader.__iter__c C s$ t | j�}| jj| jt|�d� |S �N�rQ )�nextr� rA rQ r� �len)rI �linerL rL rM �__next__� s z_Reader.__next__c C s | j S rX )r� r[ rL rL rM �closed� s z_Reader.closedc C s | j �� S rX )r� �filenor[ rL rL rM r� � s z_Reader.filenoc C s | j �� S rX )r� �isattyr[ rL rL rM r� � s z_Reader.isattyc C s | j jS rX )r� �moder[ rL rL rM r� � s z _Reader.modec C s | j jS rX )r� �namer[ rL rL rM r� � s z _Reader.namec C s | j �� S rX )r� �readabler[ rL rL rM r� � s z_Reader.readablec C s | j �� S rX )r� �seekabler[ rL rL rM r� � s z_Reader.seekablec C s dS r� rL r[ rL rL rM �writable� s z_Reader.writable���)�sizerO c C s& | j �|�}| jj| jt|�d� |S r� )r� �readrA rQ r� r� )rI r� �blockrL rL rM r� � s z _Reader.read)�bc C s" | j �|�}| jj| j|d� |S r� )r� �readintorA rQ r� )rI r� �nrL rL rM r� � s z_Reader.readintoc C s& | j �|�}| jj| jt|�d� |S r� )r� �readlinerA rQ r� r� )rI r� r� rL rL rM r� s z_Reader.readline)�hintrO c C s, | j �|�}| jj| jttt|��d� |S r� )r� � readlinesrA rQ r� �sum�mapr� )rI r� �linesrL rL rM r� s z_Reader.readlinesc C s | j r| j�� d| _d S )NT)r� r� r� r� r[ rL rL rM r� s z _Reader.closer )�offset�whencerO c C s$ | j �||�}| jj| j|d� |S )N�rF )r� �seekrA rU r� )rI r� r� �posrL rL rM r� s z _Reader.seekc C s | j �� S rX )r� �tellr[ rL rL rM r� s z _Reader.tell)�srO c C s t d��d S )N�write�r )rI r� rL rL rM r� s z _Reader.write)r� rO c C s t d��d S )N� writelinesr� )rI r� rL rL rM r� s z_Reader.writelines)T)r� )r� )r� )r ),re rf rg rh r r< �boolrH r\ r r# rj r rd r� �bytesr� �propertyr� �intr� r� �strr� r� r� r� r� r� r% � bytearray� memoryviewr r� r� r r� r� r� r� r r� r r� rL rL rL rM r� � sJ �� � r� c @ sT e Zd ZdZdedd�dd�Zed�dd �Zeee ee ee dd �d d �Z dS ) � _ReadContextzEA utility class to handle a context for both a reader and a progress.r@ N)rA �readerrO c C s || _ || _d S rX )rA r� )rI rA r� rL rL rM rH " s z_ReadContext.__init__rN c C s | j �� | j�� S rX )rA rZ r� r\ r[ rL rL rM r\ & s z_ReadContext.__enter__r] c C s | j �� | j�|||� d S rX )rA �stopr� rd rc rL rL rM rd * s z_ReadContext.__exit__) re rf rg rh r> rH r\ r r# rj r rd rL rL rL rM r� s �r� � Reading...) rt rv rw rx ry rz r{ r| r} r~ r )�fileru rt rv rw rx ry rz r{ r| r} r~ r rO c C sh |rt d�gng } | �t|| | | d�t� t� f� t| |||||pDd| d��}|j| ||d�}t||�S )a Read 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. r� r� rm r� )ru rt )r� r� r� �DownloadColumnr� r@ � wrap_filer� )r� ru rt rv rw rx ry rz r{ r| r} r~ r r� rA r� rL rL rM r� 4 s0 %���� � r� r� ) ru rt rv rw rx ry rz r{ r| r} r~ r � PathLike[str]�rt�r)r� r� � buffering�encoding�errors�newlineru rt rv rw rx ry rz r{ r| r} r~ r rO c C s d S rX rL �r� r� r� r� r� r� ru rt rv rw rx ry rz r{ r| r} r~ r rL rL rM �openu s r� �rbc C s d S rX rL r� rL rL rM r� � s c C sr |rt d�gng }|�t| |||d�t� t� f� t||| | | | pDd|d��}|j| |||||||d�}t||�S )a� Read 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. r� r� rm r� )r� r� r� r� r� ru rt )r� r� r� r� r� r@ r� r� )r� r� r� r� r� r� ru rt rv rw rx ry rz r{ r| r} r~ r r� rA r� rL rL rM r� � sB 1���� � � c @ sj e Zd ZU dZdZee ed< dee dd�dd�Z ed�dd �Z d e d �d d �Z e d e d �dd��ZdS )�ProgressColumnz3Base class for a widget to use in progress display.N� max_refresh)� table_columnrO c C s || _ i | _d | _d S rX )� _table_column�_renderable_cache� _update_time)rI r� rL rL rM rH s zProgressColumn.__init__rN c C s | j p t� S )z.Get a table column, used to build tasks table.)r� r8 r[ rL rL rM �get_table_column s z ProgressColumn.get_table_column�Task�r� rO c C sp |� � }| jdurR|jsRz| j|j \}}W n ty> Y n0 || j |krR|S | �|�}||f| j|j< |S )a Called 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). N)ry r� rF r� �id�KeyError�render)rI r� � current_time� timestamp� renderablerL rL rM �__call__ s zProgressColumn.__call__c C s dS )z"Should return a renderable object.NrL �rI r� rL rL rM r� " s zProgressColumn.render)N)re rf rg rh r� r ri �__annotations__r8 rH r� r1 r� r r� rL rL rL rM r� � s r� c sD e Zd ZdZd dd�eee d�� fdd�Zded �d d �Z� Z S ) �RenderableColumnz�A column to insert an arbitrary column. Args: renderable (RenderableType, optional): Any renderable. Defaults to empty string. � N�r� )r� r� c s || _ t� j|d� d S �Nr� )r� rG rH )rI r� r� rJ rL rM rH . s zRenderableColumn.__init__r� r� c C s | j S rX )r� r� rL rL rM r� 4 s zRenderableColumn.render)r� ) re rf rg rh r1 r r8 rH r� rk rL rL rJ rM r� ' s ���r� c sb e Zd ZdZdeee eeee d�� fdd � Z deee edd �d d �Z d e d�dd�Z � ZS )� SpinnerColumna� A 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 " ". �dots�progress.spinner� �?� N)� spinner_namer{ �speed� finished_textr� c s< t |||d�| _t|t�r$t�|�n|| _t� j|d� d S )N�r{ r� r� ) r6 �spinner� isinstancer� r: � from_markupr� rG rH )rI r� r{ r� r� r� rJ rL rM rH B s � �zSpinnerColumn.__init__)r� � spinner_styler� rO c C s t |||d�| _dS )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. r� N)r6 r� )rI r� r� r� rL rL rM � set_spinnerR s zSpinnerColumn.set_spinnerr� r� c C s |j r | jn| j�|�� �}|S rX )�finishedr� r� r� ry )rI r� �textrL rL rM r� a s ��zSpinnerColumn.render)r� r� r� r� N)r� r� )re rf rg rh r� r r7 ri r; r8 rH r� r1 r� rk rL rL rJ rM r� 8 s, �� �� r� c sL e Zd ZdZd eeeeee ee dd�� fdd� Z d e d �d d �Z � ZS )r� zA column containing text.�none�leftTN)� text_formatr{ �justify�markup� highlighterr� rO c s: || _ || _|| _|| _|| _t� j|p0tdd�d� d S )NT��no_wrapr� )r� r� r{ r� r� rG rH r8 )rI r� r{ r� r� r� r� rJ rL rM rH m s zTextColumn.__init__r� r� c C sR | j j|d�}| jr*tj|| j| jd�}nt|| j| jd�}| jrN| j�|� |S �N�r� )r{ r� ) r� �formatr� r: r� r{ r� r� � highlight)rI r� �_textr� rL rL rM r� } s zTextColumn.render)r� r� TNN)re rf rg rh r� r7 r0 r� r r2 r8 rH r: r� rk rL rL rJ rM r� j s ��r� c sL e Zd ZdZdee eeeeee dd�� fd d � Zd e d �d d�Z � Z S )r� a Renders 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". �( rn ro rp rq N)� bar_widthr{ r| r} r~ r� rO c s0 || _ || _|| _|| _|| _t� j|d� d S r� )r r{ r| r} r~ rG rH )rI r r{ r| r} r~ r� rJ rL rM rH � s zBarColumn.__init__r� r� c C s^ t |jdurtd|j�ndtd|j�| jdu r2dn td| j�|j |�� | j| j| j | j d� S )z&Gets a progress bar widget for a task.Nr r+ ) ru rF �width�pulse�animation_timer{ r| r} r~ ) r5 ru �maxrF r �startedry r{ r| r} r~ r� rL rL rM r� � s �zBarColumn.render)r rn ro rp rq N) re rf rg rh r r� r7 r8 rH r5 r� rk rL rL rJ rM r� � s" ��r� c @ s e Zd ZdZded�dd�ZdS )�TimeElapsedColumnzRenders time elapsed.r� r� c C sJ |j r |jn|j}|du r&tddd�S ttdt|��d�}tt|�dd�S )zShow time elapsed.N�-:--:--�progress.elapsed�r{ r )�seconds)r� � finished_time�elapsedr: r r r� r� )rI r� r �deltarL rL rM r� � s zTimeElapsedColumn.renderN�re rf rg rh r: r� rL rL rL rM r � s r c sh e Zd ZdZdeeeeeee ee edd � � fd d � Z e ee ed �d d��Zded�dd�Z� ZS )r� a Show 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. �-[progress.percentage]{task.percentage:>3.0f}%r� r� r� TNF) r� �text_format_no_percentager{ r� r� r� r� r� rO c s( || _ || _t� j||||||d� d S )N)r� r{ r� r� r� r� )r r� rG rH ) rI r� r r{ r� r� r� r� r� rJ rL rM rH � s �zTaskProgressColumn.__init__)r� rO c C sN |du rt ddd�S t�t|�g d�d�\}}|| }t |d�|� d�dd�S ) z�Render the speed in iterations per second. Args: task (Task): A Task object. Returns: Text: Text object containing the task speed. Nr� zprogress.percentager )r� u ×10³u ×10⁶u ×10⁹u ×10¹²�� z.1fz it/s)r: r, �pick_unit_and_suffixr� )�clsr� �unit�suffix� data_speedrL rL rM � render_speed� s �z TaskProgressColumn.render_speedr� r� c C s� |j d u r"| jr"| �|jp |j�S |j d u r2| jn| j}|j|d�}| jr`t j || j | j d�}nt || j | j d�}| j r�| j �|� |S r� )ru r� r �finished_speedr� r r� r r� r: r� r{ r� r� r )rI r� r� r r� rL rL rM r� � s � zTaskProgressColumn.render)r r� r� r� TNNF)re rf rg rh r� r7 r0 r� r r2 r8 rH � classmethodri r: r r� rk rL rL rJ rM r� � s. ��r� c sD e Zd ZdZdZd eeee d�� fdd� Zde d �d d �Z � Z S ) r� a Renders 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. � �?FN)�compactr� r� c s || _ || _t� j|d� d S r� )r r� rG rH )rI r r� r� rJ rL rM rH s z TimeRemainingColumn.__init__r� r� c C s� | j r|jr|j}d}n |j}d}|jdu r8td|d�S |du rVt| jrLdnd|d�S tt|�d�\}}t|d�\}}| jr�|s�|d �d |d ��}n|d �d |d �d |d ��}t||d�S ) zShow time remaining.r zprogress.remainingNr� r z--:--r �< �02d�:�d) r� r� r �time_remainingru r: r �divmodr� )rI r� � task_timer{ �minutesr �hours� formattedrL rL rM r� s zTimeRemainingColumn.render)FFN) re rf rg rh r� r� r r8 rH r: r� rk rL rL rJ rM r� s �� r� c @ s e Zd ZdZded�dd�ZdS )�FileSizeColumnzRenders completed filesize.r� r� c C s t �t|j��}t|dd�S )�Show data completed.zprogress.filesizer )r, �decimalr� rF r: �rI r� � data_sizerL rL rM r� 9 s zFileSizeColumn.renderNr rL rL rL rM r+ 6 s r+ c @ s e Zd ZdZded�dd�ZdS )�TotalFileSizeColumnzRenders total filesize.r� r� c C s* |j durt�t|j ��nd}t|dd�S )r, Nr� zprogress.filesize.totalr )ru r, r- r� r: r. rL rL rM r� B s zTotalFileSizeColumn.renderNr rL rL rL rM r0 ? s r0 c s> e Zd ZdZd eee d�� fdd� Zded�d d �Z � Z S ) �MofNCompleteColumnaH Renders 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 "/". �/N)� separatorr� c s || _ t� j|d� d S r� )r3 rG rH )rI r3 r� rJ rL rM rH T s zMofNCompleteColumn.__init__r� r� c C sP t |j�}|jdur t |j�nd}tt|��}t||� d��| j� |� �dd�S )zShow completed/total.N�?r$ �progress.downloadr )r� rF ru r� r� r: r3 )rI r� rF ru � total_widthrL rL rM r� X s �zMofNCompleteColumn.render)r2 N) re rf rg rh r� r r8 rH r: r� rk rL rL rJ rM r1 H s r1 c s@ e Zd ZdZd eee dd�� fdd� Zded�d d �Z � Z S ) r� z�Renders 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. FN)� binary_unitsr� rO c s || _ t� j|d� d S r� )r7 rG rH )rI r7 r� rJ rL rM rH j s zDownloadColumn.__init__r� r� c C s� t |j�}|jdur t |j�n|}| jr@t�|g d�d�\}}nt�|g d�d�\}}|dkrbdnd}|| }|d|� d ��}|jdur�t |j�} | | } | d|� d ��} nd } |� d | � d |� �} t| d d�} | S )z.Calculate common unit for completed and total.N) r� �KiB�MiB�GiB�TiB�PiB�EiB�ZiB�YiBi ) r� �kB�MB�GB�TB�PB�EB�ZB�YBr r+ r z,.�fr4 r2 r� r5 r )r� rF ru r7 r, r r: )rI r� rF � unit_and_suffix_calculation_baser r � precision�completed_ratio� completed_strru � total_ratio� total_str�download_status� download_textrL rL rM r� p s2 �� � zDownloadColumn.render)FN) re rf rg rh r� r r8 rH r: r� rk rL rL rJ rM r� c s ��r� c @ s e Zd ZdZded�dd�ZdS )�TransferSpeedColumnz&Renders human readable transfer speed.r� r� c C s@ |j p |j}|du r tddd�S t�t|��}t|� d�dd�S )zShow data transfer speed.Nr4 zprogress.data.speedr z/s)r r� r: r, r- r� )rI r� r� r rL rL rM r� � s zTransferSpeedColumn.renderNr rL rL rL rM rQ � s rQ c @ s" e Zd ZU dZeed< eed< dS )�ProgressSamplez$Sample of progress for a given time.r� rF N)re rf rg rh ri r� rL rL rL rM rR � s rR c @ s� e Zd ZU dZeed< eed< ee ed< eed< e ed< dZ ee ed< d Z e ed < e ed �Zeeef ed < e dd d d�Zee ed< e dd d d�Zee ed< dZee ed< e dd� d d d�Zee ed< e d ed�Zeed< ed�dd�Zee d�dd ��Z eee d�d d ��Z eee d�d d ��Z ee d�d!d"��Z eed�d#d$��Z eee d�d%d&��Z!eee d�d'd(��Z"dd�d)d*�Z#dS )+r� z�Information regarding a progress task. This object should be considered read-only outside of the :class:`~Progress` class. r� rt ru rF � _get_timeNr T�visible)�default_factory�fieldsF)�default�init�repr� start_time� stop_timer c C s t dd�S )Nr )�maxlenr rL rL rL rM �<lambda>� � z Task.<lambda>)rU rX rY � _progress)rY rU �_lockrN c C s | � � S )z(float: Get the current time, in seconds.)rS r[ rL rL rM ry � s z Task.get_timec C s | j duS )z#bool: Check if the task as started.N)rZ r[ rL rL rM r � s z Task.startedc C s | j du rdS | j | j S )zPOptional[float]: Get the number of steps remaining, if a non-None total was set.N�ru rF r[ rL rL rM � remaining� s zTask.remainingc C s2 | j du rdS | jdur$| j| j S | �� | j S )z]Optional[float]: Time elapsed since task was started, or ``None`` if the task hasn't started.N)rZ r[ ry r[ rL rL rM r � s z Task.elapsedc C s | j duS )z Check if the task has finished.N)r r[ rL rL rM r� � s z Task.finishedc C s. | j s dS | j| j d }tdtd|��}|S )zOfloat: Get progress of task as a percentage. If a None total was set, returns 0� � Y@)ru rF �minr )rI rF rL rL rM � percentage� s zTask.percentagec C s� | j du rdS | j�� | j}|s0W d � dS |d j|d j }|dkr\W d � dS t|�}t|� tdd� |D ��}|| }|W d � S 1 s�0 Y dS )z=Optional[float]: Get the estimated speed in steps per second.Nr� r c s s | ] }|j V qd S rX r� )�.0�samplerL rL rM � <genexpr> r^ z Task.speed.<locals>.<genexpr>)rZ r` r_ r� �iterr� r� )rI rA � total_time� iter_progress�total_completedr� rL rL rM r� s z Task.speedc C s: | j r dS | j}|sdS | j}|du r*dS t|| �}|S )zJOptional[float]: Get estimated time to completion, or ``None`` if no data.rc N)r� r� rb r )rI r� rb �estimaterL rL rM r% s zTask.time_remainingc C s | j �� d| _d| _dS )zReset progress.N)r_ �clearr r r[ rL rL rM �_reset s z Task._reset)$re rf rg rh r< r� r� r ri �GetTimeCallabler rT r� r �dictrV r r rZ r[ r r_ r rR r r` ry r� r rb r r� rf r� r% rp rL rL rL rM r� � s@ � r� c @ s� e Zd ZdZddddddddddd� eeef ee e e e e e e ee e e dd� d d �Z e eed f d �d d��Zeed �dd��Zeee d �dd��Zeee d �dd��Zee d �dd��Zdd �dd�Zdd �dd�Zed �dd �Zee e ee ee dd �d d �Z dXee e! e"e! f ee e#ee ee e e! d#�d$d%�Z$dYdd&d'�e%ee# ee ee%d(�d)d*�Z&e'j(dZddd&d,�eed-e)f e*d. e#ee ee ee ee# ee ee%d/� d0d1��Z+e'j(d[ddd&d,�eed-e)f ee*d2 e*d3 f e#ee ee ee ee# ee ee,d/� d4d1��Z+d\ddd&d,�eed-e)f ee*d. e*d3 e*d2 f e#ee ee ee ee# ee eee%e,f d/� d5d1�Z+edd6�d7d8�Z-edd6�d9d:�Z.ddddddd;�eee ee ee ee ee e e/dd<� d=d>�Z0ddd ddd?�ee ee e#ee ee e/dd@�dAdB�Z1d]ee ddD�dEdF�Z2dd �dGdH�Z3e4d �dIdJ�Z5e e4 d �dKdL�Z6e e e7dM�dNdO�Z8e4d �dPdQ�Z9d^ee ee e#e e/edS�dTdU�Z:edd6�dVdW�Z;dS )_r@ a� Renders 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. NTrm g >@F) rw rv rz �speed_estimate_periodrx �redirect_stdout�redirect_stderrry r �expand) r� rw rv rz rs rx rt ru ry r rv rO c G s� |dksJ d��t � | _| p"| �� | _|| _| | _| | _i | _td�| _ t |pRt � |||||| j d�| _ |pr| jj| _| jj| _| jj| _d S )Nr z refresh_per_second must be > 0)rw rv rz rx rt ru �get_renderable)r r` �get_default_columnsr� rs r rv �_tasksr< � _task_indexr4 r- rw rS rw ry �print�log) rI rw rv rz rs rx rt ru ry r rv r� rL rL rM rH 7 s( � zProgress.__init__.rN c C s t d�t� t� t� fS )a� Get 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� )r� r� r� r� )r rL rL rM rx [ s �z Progress.get_default_columnsc C s | j jS rX )rS rw r[ rL rL rM rw z s zProgress.consolec C s8 | j � t| j�� �W d � S 1 s*0 Y dS )z Get a list of Task instances.N)r` �listry �valuesr[ rL rL rM �tasks~ s zProgress.tasksc C s8 | j � t| j�� �W d � S 1 s*0 Y dS )zA list of task IDs.N)r` r} ry �keysr[ rL rL rM �task_ids� s zProgress.task_idsc C sX | j �> | js W d � dS tdd� | j�� D ��W d � S 1 sJ0 Y dS )z'Check if all tasks have been completed.NTc s s | ] }|j V qd S rX )r� )rg r� rL rL rM ri � r^ z$Progress.finished.<locals>.<genexpr>)r` ry �allr~ r[ rL rL rM r� � s zProgress.finishedc C s | j s| jjdd� dS )zStart the progress display.T)rP N)r rS rZ r[ rL rL rM rZ � s zProgress.startc C s( | j �� | jjs$| jjs$| j�� dS )zStop the progress display.N)rS r� rw �is_interactive� is_jupyterr{ r[ rL rL rM r� � s z Progress.stopc C s | � � | S rX rY r[ rL rL rM r\ � s zProgress.__enter__r] c C s | � � d S rX )r� rc rL rL rM rd � s zProgress.__exit__r rl rr )rs ru rF rB rt rC rO c c s� |du rt t|��pd}|du r2| j|||d�}n| j|||d� | jjr�t| ||��.}|D ]}|V | jd7 _q\W d � q�1 s�0 Y n,| j} | j } |D ]}|V | |d� | � q�dS )a� Track 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. Nra r+ ) ri r �add_taskrU rS rv r? rF rQ rP ) rI rs ru rF rB rt rC � track_thread�valuerQ rP rL rL rM r� � s 0 zProgress.trackr� )rB rt )r� ru rB rt rO c C s� d}|dur|}n:|durL| j � | j| j}W d � n1 sB0 Y |du r\td��|du rt| j||d�}n| j||d� t|| |dd�S )aj Track 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'�ru F�r� )r` ry ru � ValueErrorr� rU r� )rI r� ru rB rt � total_bytesrL rL rM r� � s *�zProgress.wrap_filer� )ru rB rt r� r� ) r� r� r� r� r� r� ru rB rt rO c C s d S rX rL � rI r� r� r� r� r� r� ru rB rt rL rL rM r� � s z Progress.openr� r� c C s d S rX rL r� rL rL rM r� s c C s� d� t|dd��} | dvr(td|����|dk} | dkrR|dkrRt�dt� d }n&| d v rx|d krltd ��n |dkrxd }|d u r�t|�j}|d u r�| j| |d�}n| j ||d� t j |d|d�} t | | |dd�} |dv r�t j | |||| d�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. r� F)�reverse)�brr� r� z invalid mode r+ r� zaline buffering (buffering=1) isn't supported in binary mode, the default buffer size will be usedr� )r� r� r z can't have unbuffered text I/ONr� r� )r� Tr� )r� r� )r� r� r� �line_buffering)rb �sortedr� �warnings�warn�RuntimeWarningr �st_sizer� rU �ior� r� � TextIOWrapper)rI r� r� r� r� r� r� ru rB rt �_moder� r� r� rL rL rM r� s> !� �)rB rO c C sH | j �. | j| }|jdu r&| �� |_W d � n1 s:0 Y dS )z�Start 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)r` ry rZ ry )rI rB r� rL rL rM � start_taskk s zProgress.start_taskc C sR | j �8 | j| }| �� }|jdu r*||_||_W d � n1 sD0 Y dS )z�Stop a task. This will freeze the elapsed time on the task. Args: task_id (TaskID): ID of task. N)r` ry ry rZ r[ )rI rB r� r� rL rL rM � stop_tasky s zProgress.stop_task)ru rF rQ rt rT rP ) rB ru rF rQ rt rT rP rV rO c K s@ | j �� | j| } | j} |dur:|| jkr:|| _| �� |durP| j|7 _|dur^|| _|durl|| _|durz|| _| j�|� | j| } | � � } | | j } | j }|j }|r�|d j | k r�|� q�| dkr�|�t| | �� | jdu�r| j| jk�r| jdu �r| j| _W d � n1 �s$0 Y |�r<| �� dS )a� Update 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 )r` ry rF ru rp rt rT rV rU ry rs r_ �popleftr� �appendrR r r rP )rI rB ru rF rQ rt rT rP rV r� �completed_start�update_completedr� �old_sample_timer_ r� rL rL rM rU � sB � ��(zProgress.update)rZ ru rF rT rt )rB rZ ru rF rT rt rV rO c K s� | � � }| j�p | j| } | �� |r*|nd| _|dur>|| _|| _|durR|| _|r\|| _|durj|| _ d| _ W d � n1 s�0 Y | � � dS )a� Reset 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) ry r` ry rp rZ ru rF rT rV rt r rP ) rI rB rZ ru rF rT rt rV r� r� rL rL rM �reset� s $zProgress.resetr+ )rB rQ rO c C s� | � � }| j�� | j| }|j}| j|7 _|j| }|| j }|j}|j} |rh|d j|k rh| � qNt|�dkr|| � qh|� t ||�� |j dur�|j|j kr�|j du r�|j |_ |j|_W d � n1 s�0 Y dS )z�Advance task by a number of steps. Args: task_id (TaskID): ID of task. advance (float): Number of steps to advance. Default is 1. r r N)ry r` ry rF rs r_ r� r� r� r� rR ru r r r� r ) rI rB rQ r� r� r� r� r� r_ r� rL rL rM rQ � s, � ��zProgress.advancec C s | j s| jjr| j�� dS )z*Refresh (render) the progress information.N)r rS rT rP r[ rL rL rM rP s zProgress.refreshc C s t | �� � }|S )z*Get a renderable for the progress display.)r/ �get_renderables)rI r� rL rL rM rw s zProgress.get_renderablec c s | � | j�}|V dS )z5Get a number of renderables for the progress display.N)�make_tasks_tabler )rI �tablerL rL rM r� s zProgress.get_renderables)r rO c sR dd� | j D �}tj|d| jd��}|D ]$� � jr(|j� fdd�| j D �� q(|S )z�Get 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. c s s. | ]&}t |t�rtd d�n |�� �� V qdS )Tr� N)r� r� r8 r� �copy)rg �_columnrL rL rM ri " s �� z,Progress.make_tasks_table.<locals>.<genexpr>)r r+ )�paddingrv c 3 s, | ]$}t |t�r |j� d �n|� �V qdS )r N)r� r� r )rg �columnr rL rM ri / s ��)r� r9 �gridrv rT �add_row)rI r � table_columnsr� rL r rM r� s � �� zProgress.make_tasks_tablec C s2 | j � | �� W d � S 1 s$0 Y dS )z+Makes the Progress class itself renderable.N)r` rw r[ rL rL rM �__rich__: s zProgress.__rich__rd )rt rZ ru rF rT rV rO c K s� | j �d t| j|||||| j| j d�}|| j| j< |rB| �| j� | j}tt| j�d �| _W d � n1 sp0 Y | �� |S )a Add 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`. )rT rV rS r` r+ N) r` r� rz ry ry r� r< r� rP ) rI rt rZ ru rF rT rV r� �new_task_indexrL rL rM r� ? s$ � 2zProgress.add_taskc C s2 | j � | j|= W d � n1 s$0 Y dS )z]Delete a task if it exists. Args: task_id (TaskID): A task ID. N)r` ry )rI rB rL rL rM � remove_taskj s zProgress.remove_task)Nr Nrl rr )N)r� NNN)r� NNN)r� r� NNN)r+ )Trd r T)<re rf rg rh r% r� r� r r. r� ri rq rH r r" rx r� rw r r� r r< r� r� rZ r� r* r\ r# rj r rd r r= r r� r� r r� �typing�overloadr� r( r� r! r� r� r rU r� rQ rP r1 rw r� r9 r� r� r� r� rL rL rL rM r@ ' sr � � $ � �� . ��� * � � � � � � � � � M�� A�� ' ! �� +r@ �__main__)�Panel)�Rule)�Syntax)r9 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_value�python)� line_numbersZfoo�barZbaz�1�2�3z:Text may be printed while the progress bars are rendering.z(In fact, [i]any[/i] renderable will workz Such as [magenta]tables[/]...z Pretty printed structures...�examplezPretty printed)�typer� z Syntax...zGive it a try!)�cycle)�record)rw rx z[red]Downloadingr r� z[green]Processingz[yellow]Thinkingr r� g333333�?g{�G�z�?�d )rl Nr TNFNrm rn ro rp rq rr FT)r� NNN)r� NNN)r� r� NNN)�r� �sysr� r� �abcr r � collectionsr � dataclassesr r �datetimer r r �mathr r �operatorr �osr r � threadingr r r �typesr r r r r r r r r r r r r r r! r" r# r$ r% � version_infor( � pip._vendor.typing_extensionsr* r� r, r- rw r. r/ r0 r1 r� r2 �jupyterr3 rS r4 � progress_barr5 r� r6 r{ r7 r� r8 r9 r� r: r; r� r< r= ri rq r> r? r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r+ r0 r1 r� rQ rR r� r@ re �random�time�panelr� �ruler� �syntaxr� r� Zprogress_renderables� itertoolsr� Zexamplesrx rA r� Ztask1Ztask2Ztask3r� rU �sleep�randintr| r� rL rL rL rM �<module> s8 P * �� Lg�� A �� � �� � �� � V*2 * H0 1 } R � � ����
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка