FileMgr

✏️ /usr/lib/python3/dist-packages/s3transfer/__pycache__/subscribers.cpython-312.pyc

✕ Tutup

�

�����<�e#�����������������������<�����d�dl�mZ�d�dlmZ�d�dlmZ��G�d��d�������Zy)�����)�	lru_cache)�accepts_kwargs)�InvalidSubscriberMethodErrorc��������������������`�������e�Zd�ZdZg�d�Z��fd�Ze�e��������d������������������Zd��Z	d��Z
d��Z��xZS�)�BaseSubscriberz�The base subscriber class

It is recommended that all subscriber implementations subclass and then
    override the subscription methods (i.e. on_{subsribe_type}() methods).
    )�queued�progress�donec������������������B������|�j���������������������������t���������|��	��|��������S�)N)�_validate_subscriber_methods�super�__new__)�cls�args�kwargs�	__class__s���   ��8/usr/lib/python3/dist-packages/s3transfer/subscribers.pyr���zBaseSubscriber.__new__���s��������(�(�*��w��s�#�#�����c�����������������������|�j�������������������D�]C��}t��������|�d|z����������}t��������|�������st��������d|z����������t	��������|�������r�7t��������d|z�����������y�)N�on_z&Subscriber method %s must be callable.z=Subscriber method %s must accept keyword arguments (**kwargs))�VALID_SUBSCRIBER_TYPES�getattr�callabler���r���)r����subscriber_type�subscriber_methods���   r���r���z+BaseSubscriber._validate_subscriber_methods ���sq������� #�9�9��	�O� '��U�_�-D� E���-�.�2�<�'�(����
�"�"3�4�2�+�->�?����	r���c������������������������y)a���Callback to be invoked when transfer request gets queued

This callback can be useful for:

* Keeping track of how many transfers have been requested
            * Providing the expected transfer size through
              future.meta.provide_transfer_size() so a HeadObject would not
              need to be made for copies and downloads.

:type future: s3transfer.futures.TransferFuture
        :param future: The TransferFuture representing the requested transfer.
        N����self�futurer���s���   r����	on_queuedzBaseSubscriber.on_queued1�����������	
r���c������������������������y)aj��Callback to be invoked when progress is made on transfer

This callback can be useful for:

* Recording and displaying progress

:type future: s3transfer.futures.TransferFuture
        :param future: The TransferFuture representing the requested transfer.

:type bytes_transferred: int
        :param bytes_transferred: The number of bytes transferred for that
            invocation of the callback. Note that a negative amount can be
            provided, which usually indicates that an in-progress request
            needed to be retried and thus progress was rewound.
        Nr���)r���r ����bytes_transferredr���s���    r����on_progresszBaseSubscriber.on_progress@���s������ �	
r���c������������������������y)a���Callback to be invoked once a transfer is done

This callback can be useful for:

* Recording and displaying whether the transfer succeeded or
              failed using future.result()
            * Running some task after the transfer completed like changing
              the last modified time of a downloaded file.

:type future: s3transfer.futures.TransferFuture
        :param future: The TransferFuture representing the requested transfer.
        Nr���r���s���   r����on_donezBaseSubscriber.on_doneR���r"���r���)
�__name__�
__module__�__qualname__�__doc__r���r����classmethodr���r���r!���r%���r'����
__classcell__)r���s���@r���r���r������sB���������<��$����[�
�����
�

�
�$

r���r���N)�	functoolsr����s3transfer.compatr����s3transfer.exceptionsr���r���r���r���r����<module>r1������s������ ��,��>�L
��L
r���

Batal

⬅ s3transfer 16 item

Nama	Tipe	Ukuran	Diubah	Perm	Aksi
📄 __init__.cpython-312.pyc	pyc	33.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 bandwidth.cpython-312.pyc	pyc	18.1 KB	15/06/26 13:45	0644	✏️ ⬇
📄 compat.cpython-312.pyc	pyc	2.5 KB	15/06/26 13:45	0644	✏️ ⬇
📄 constants.cpython-312.pyc	pyc	545 B	15/06/26 13:45	0644	✏️ ⬇
📄 copies.cpython-312.pyc	pyc	11.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 crt.cpython-312.pyc	pyc	36.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 delete.cpython-312.pyc	pyc	2.6 KB	15/06/26 13:45	0644	✏️ ⬇
📄 download.cpython-312.pyc	pyc	29.2 KB	15/06/26 13:45	0644	✏️ ⬇
📄 exceptions.cpython-312.pyc	pyc	1.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 futures.cpython-312.pyc	pyc	27.5 KB	15/06/26 13:45	0644	✏️ ⬇
📄 manager.cpython-312.pyc	pyc	26.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 processpool.cpython-312.pyc	pyc	40.7 KB	15/06/26 13:45	0644	✏️ ⬇
📄 subscribers.cpython-312.pyc	pyc	3.7 KB	15/06/26 13:45	0644	✏️ ⬇
📄 tasks.cpython-312.pyc	pyc	13.4 KB	15/06/26 13:45	0644	✏️ ⬇
📄 upload.cpython-312.pyc	pyc	30.3 KB	15/06/26 13:45	0644	✏️ ⬇
📄 utils.cpython-312.pyc	pyc	34.8 KB	15/06/26 13:45	0644	✏️ ⬇

✏️ Rename

🔑 Ubah Permission