o
    ED©i&  ã                   @   s,   d dl mZ d dlmZ G dd„ deƒZdS )é   )Údefines)Úread_varintc                       s,   e Zd Z‡ fdd„Zdd„ Zdd„ Z‡  ZS )ÚProgressc                    s<   d| _ d| _d| _d| _d| _d| _d| _tt| ƒ 	¡  d S )Né    )
ÚrowsÚbytesÚ
total_rowsÚtotal_bytesÚwritten_rowsÚwritten_bytesÚ
elapsed_nsÚsuperr   Ú__init__)Úself©Ú	__class__© úS/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_driver/progress.pyr      s   zProgress.__init__c                 C   s|   t |ƒ| _t |ƒ| _|j}|tjkrt |ƒ| _|tjkr!t |ƒ| _|tj	kr0t |ƒ| _
t |ƒ| _|tjkr<t |ƒ| _d S d S ©N)r   r   r   Úused_revisionr   Ú-DBMS_MIN_REVISION_WITH_TOTAL_ROWS_IN_PROGRESSr   Ú6DBMS_MIN_PROTOCOL_VERSION_WITH_TOTAL_BYTES_IN_PROGRESSr	   Ú(DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFOr
   r   Ú<DBMS_MIN_PROTOCOL_VERSION_WITH_SERVER_QUERY_TIME_IN_PROGRESSr   )r   Úserver_infoÚfinÚrevisionr   r   r   Úread   s"   



ÿ



ÿþzProgress.readc                 C   st   |  j |j 7  _ |  j|j7  _|  j|j7  _|  j|j7  _|  j|j7  _|  j|j7  _|  j|j7  _d S r   )r   r   r   r	   r
   r   r   )r   Úanother_progressr   r   r   Ú	increment%   s   zProgress.increment)Ú__name__Ú
__module__Ú__qualname__r   r   r   Ú__classcell__r   r   r   r   r      s    r   N)Ú r   Úvarintr   Úobjectr   r   r   r   r   Ú<module>   s    