asyncio.cpython-312.pyc•4.47 kB
�
lMg�
� �^ � d Z ddlZddlmZ ddlmZ ddgiZg d�Z G d � d
e� Z d � Z
e Ze
Z y) z�
Asynchronous progressbar decorator for iterators.
Includes a default `range` iterator printing to `stderr`.
Usage:
>>> from tqdm.asyncio import trange, tqdm
>>> async for i in trange(10):
... ...
� N)� version_info� )�tqdmz github.com/� casperdcl)� tqdm_asyncio�taranger �trangec �j � � e Zd ZdZd
� fd� Zd� Zd� Zd� Zedddd�d�� Z edddd�d �� Z
� xZ S ) r z0
Asynchronous-friendly version of tqdm.
Nc � �� t �| � |g|��i |�� d| _ |�ot |d� r|j | _ d| _ y t |d� r|j | _ y t |� | _ | j j | _ y y )NF� __anext__T�__next__) �super�__init__�iterable_awaitable�hasattrr �
iterable_nextr
�iter�iterable_iterator)�self�iterable�args�kwargs� __class__s ��XC:\Users\noahv\Documents\GitHub\clickup-operator\.venv\Lib\site-packages\tqdm/asyncio.pyr ztqdm_asyncio.__init__ s� �� �
����3�D�3�F�3�"'�� � � ��x��-�%-�%7�%7��"�*.��'���:�.�%-�%6�%6��"�)-�h� ��&�%)�%;�%;�%D�%D��"� � c � � | S �N� )r s r � __aiter__ztqdm_asyncio.__aiter__$ s � �� r c � � K � | j r| j � � d { ��� }n| j � }| j � |S 7 �'# t $ r | j � t
�t $ r | j � � w xY w�wr )r r �update�
StopIteration�close�StopAsyncIteration�
BaseException)r �ress r r ztqdm_asyncio.__anext__' sy � �� � ��&�&� � .� .� 0�0���(�(�*�� �K�K�M��J� 1��
� %� �J�J�L�$� $� � � �J�J�L� � �s, �B � A
�A �&A
�
B � A
�
9B�B c �: � | j j |i |��S r )r �send)r r r s r r( ztqdm_asyncio.send6 s � �!�t�}�}�!�!�4�2�6�2�2r ��loop�timeout�totalc + � K � |� t |� }i }t dd dk r||d< | t j |fd|i|��fd|i|��E d{ ��� y7 ��w)z5
Wrapper for `asyncio.as_completed`.
N� )� �
r* r+ r, )�lenr �asyncio� as_completed)�cls�fsr* r+ r, � tqdm_kwargsr s r r3 ztqdm_asyncio.as_completed9 sl � �� �
�=���G�E��� ��� �g� %� !�F�6�N��w�+�+�B�J��J�6�J� 3� "�3�&1�3� 3� 3�s �AA�A
�Ac � � K � d� }t |� D ��cg c] \ }} |||� �� } }} | j | f|||d�|��D �cg c] }|� d{ ��� �� }
}t |
� D � �cg c] \ } }|�� c}} S c c}}w 7 �,c c}w c c}} w �w)z/
Wrapper for `asyncio.gather`.
c � �& K � | |� d { ��� fS 7 ��wr r )�i�fs r �wrap_awaitablez+tqdm_asyncio.gather.<locals>.wrap_awaitableK s � �� ��A�g�:� �g�s ���r) N)� enumerater3 �sorted) r4 r* r+ r, r5 r6 r; r9 r: �ifsr& �_s r �gatherztqdm_asyncio.gatherF s� � �� �
� 1:�"�
�>�
���1�~�a��#�
��>� 0�� 0� 0�� !M�4��7<�!M�@K�!M� N� !M�1�Q�w�w� !M�� N� $�S�k�*�k�d�a���k�*�*�� ?��� N��*�s? �B�A4� B�
A<�
A:
�A<�B�$ B�0
B�:A<�< Br ) �__name__�
__module__� __qualname__�__doc__r r r r( � classmethodr3 r@ �
__classcell__)r s @r r r sS �� �� E��
� 3� �&*�D��
3� �
3� �$(�$�d�
+� �
+r r c �& � t t | � fi |��S )zE
A shortcut for `tqdm.asyncio.tqdm(range(*args), **kwargs)`.
)r �range)r r s r r r T s � � ��t� � /�� /�/r ) rD r2 �sysr �stdr �std_tqdm�
__author__�__all__r r r r r r �<module>rN sD ��� � � !��k�]�
+�
�
7��>+�8� >+�B0� �� �r