U EZh @s6ddlmZddlmZddlmZGdddZdS)) lru_cache)accepts_kwargs)InvalidSubscriberMethodErrorcsReZdZdZdddgZfddZeeddZd d Z d d Z d dZ Z S)BaseSubscriberzThe base subscriber class It is recommended that all subscriber implementations subclass and then override the subscription methods (i.e. on_{subsribe_type}() methods). Zqueuedprogressdonecs|t|S)N)_validate_subscriber_methodssuper__new__)clsargskwargs __class__]/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/s3transfer/subscribers.pyr szBaseSubscriber.__new__cCsN|jD]B}t|d|}t|s0td|dt|std|dqdS)NZon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs))VALID_SUBSCRIBER_TYPESgetattrcallablerr)r Zsubscriber_typeZsubscriber_methodrrrr s   z+BaseSubscriber._validate_subscriber_methodscKsdS)aCallback 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. Nrselffuturer rrr on_queued0s 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 rrr on_progress?szBaseSubscriber.on_progresscKsdS)aCallback 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. Nrrrrron_doneQs zBaseSubscriber.on_done) __name__ __module__ __qualname____doc__rr classmethodrrrrr __classcell__rrrrrs   rN) functoolsrZs3transfer.compatrZs3transfer.exceptionsrrrrrr s