/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/__pycache__
Edit: /usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/__pycache__/subscribers.cpython-313.pyc (3673B)
ó
”ø•j
ã ó< • S SK Jr S SKJr S SKJr " S S5 rg)é )Ú lru_cache)Úaccepts_kwargs)Ú InvalidSubscriberMethodErrorc ó` ^ • \ rS rSrSr/ SQrU 4S jr\\S 5 5 r S r
S r S r S r
U =r$ )
ÚBaseSubscriberé z«The base subscriber class
It is recommended that all subscriber implementations subclass and then
override the subscription methods (i.e. on_{subscribe_type}() methods).
)ÚqueuedÚprogressÚdonec óB >• U R 5 [ TU ] U 5 $ )N)Ú _validate_subscriber_methodsÚsuperÚ__new__)ÚclsÚargsÚkwargsÚ __class__s €ÚI/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/subscribers.pyr ÚBaseSubscriber.__new__ s ø€ Ø ×(Ñ(Ô*܉w‰˜sÓ#Ð#ó c óÄ • U R HP n[ U SU- 5 n[ U5 ( d [ SU S35 e[ U5 ( a MC [ SU S35 e g )NÚon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs))ÚVALID_SUBSCRIBER_TYPESÚgetattrÚcallabler r )r Úsubscriber_typeÚsubscriber_methods r r
Ú+BaseSubscriber._validate_subscriber_methods s| € ð #× 9Ô 9ˆOÜ '¨¨U°_Ñ-DÓ EÐ ÜÐ -×.Ñ.Ü2Ø(Ð):Ð(;Ð;MÐNóð ô "Ð"3×4Ó4Ü2Ø(Ð):Ð(;ð <+ð +óð ò :r c ó • g)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_queuedÚBaseSubscriber.on_queued0 ó € ð
r c ó • g)a 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_progressÚBaseSubscriber.on_progress? s € ð
r c ó • g)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_doneÚBaseSubscriber.on_doneQ r& r r )Ú__name__Ú
__module__Ú __qualname__Ú__firstlineno__Ú__doc__r r Ú classmethodr r
r$ r) r, Ú__static_attributes__Ú
__classcell__)r s @r r r sE ø† ñò <Ðõ$ð Øñ ó ó ð ò
ò
÷$
ð
r r N)Ú functoolsr Ús3transfer.compatr Ús3transfer.exceptionsr r r r r Ú
r9 s ðõ å ,Ý >÷K
ò K
r