403Webshell
Server IP : 3.96.16.70  /  Your IP : 216.73.216.15
Web Server : Apache
System : Linux ip-172-31-26-103.ca-central-1.compute.internal 6.1.163-186.299.amzn2023.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Feb 24 16:35:42 UTC 2026 x86_64
User : ec2-user ( 1000)
PHP Version : 8.4.18
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : OFF
Directory :  /lib/python3.9/site-packages/awscli/s3transfer/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /lib/python3.9/site-packages/awscli/s3transfer/__pycache__/subscribers.cpython-39.opt-1.pyc
a

yA�i�
�@s*ddlmZddlmZGdd�d�ZdS)�)�accepts_kwargs)�InvalidSubscriberMethodErrorcsLeZdZdZgd�Z�fdd�Zedd��Zdd�Zd	d
�Z	dd�Z
�ZS)
�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).
    )ZqueuedZprogressZdonecs|��t��|�S)N)�_validate_subscriber_methods�super�__new__)�cls�args�kwargs��	__class__��A/usr/lib/python3.9/site-packages/awscli/s3transfer/subscribers.pyrszBaseSubscriber.__new__cCsN|jD]B}t|d|�}t|�s0td|�d���t|�std|�d���qdS)NZon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs))�VALID_SUBSCRIBER_TYPES�getattr�callablerr)rZsubscriber_typeZsubscriber_methodr
r
rrs

�
�z+BaseSubscriber._validate_subscriber_methodscKsdS)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.
        Nr
��self�futurer
r
r
r�	on_queued-s
zBaseSubscriber.on_queuedcKsdS)ajCallback 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
)rrZbytes_transferredr
r
r
r�on_progress<szBaseSubscriber.on_progresscKsdS)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
rr
r
r�on_doneNs
zBaseSubscriber.on_done)�__name__�
__module__�__qualname__�__doc__rr�classmethodrrrr�
__classcell__r
r
rrrs
rN)Zs3transfer.compatrZs3transfer.exceptionsrrr
r
r
r�<module>
s

Youez - 2016 - github.com/yon3zu
LinuXploit