Ë ò`2f#ãó<—ddlmZddlmZddlmZGd„d«Zy)é)Ú lru_cache)Úaccepts_kwargs)ÚInvalidSubscriberMethodErrorcó`‡—eZdZdZgd¢Zˆfd„Zee«d„««Zd„Z d„Z d„Z ˆxZ S)Ú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 €úV/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/s3transfer/subscribers.pyrzBaseSubscriber.__new__sø€Ø ×(Ñ(Ô*܉w‰˜sÓ#Ð#ócó¨—|jD]C}t|d|z«}t|«std|z«‚t |«rŒ7td|z«‚y)NÚon_z&Subscriber method %s must be callable.z=Subscriber method %s must accept keyword arguments (**kwargs))ÚVALID_SUBSCRIBER_TYPESÚgetattrÚcallablerr)rÚsubscriber_typeÚsubscriber_methods rr z+BaseSubscriber._validate_subscriber_methods sq€ð #×9Ñ9ò ˆOÜ '¨¨U°_Ñ-DÓ EÐ ÜÐ-Ô.Ü2Ø<Ø'ñ(óðô "Ð"3Õ4Ü2ð+Ø->ñ?óðñ rc ó—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Úfuturers rÚ on_queuedzBaseSubscriber.on_queued1ó€ð rc ó—y)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)rr Úbytes_transferredrs rÚ on_progresszBaseSubscriber.on_progress@s€ð rc ó—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. Nrrs rÚon_donezBaseSubscriber.on_doneRr"r) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrÚ classmethodrr r!r%r'Ú __classcell__)rs@rrrsBø„ñò <Ðô$ðÙƒ[ñ óóð ò  ò ö$  rrN)Ú functoolsrÚs3transfer.compatrÚs3transfer.exceptionsrrrrrúr1sðõ å,Ý>÷L òL r