ó ³vKg ãó<•SSKJr SSKJr SSKJr "SS5rg)é)Ú lru_cache)Úaccepts_kwargs)ÚInvalidSubscriberMethodErrorcó`^•\rSrSrSr/SQrU4Sjr\\S55r Sr Sr Sr 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_{subsribe_type}() methods). )ÚqueuedÚprogressÚdonecóB>•UR5 [TU] U5$)N)Ú_validate_subscriber_methodsÚsuperÚ__new__)ÚclsÚargsÚkwargsÚ __class__s €ÚV/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/s3transfer/subscribers.pyrÚBaseSubscriber.__new__sø€Ø ×(Ñ(Ô*܉w‰˜sÓ#Ð#ócóÄ•URHPn[USU-5n[U5(d[SUS35e[ U5(aMC[SUS35e g)NÚon_zSubscriber method z must be callable.z) must accept keyword arguments (**kwargs))ÚVALID_SUBSCRIBER_TYPESÚgetattrÚcallablerr)rÚsubscriber_typeÚsubscriber_methods rr Ú+BaseSubscriber._validate_subscriber_methods s|€ð #×9Ô9ˆOÜ '¨¨U°_Ñ-DÓ EÐ ÜÐ-×.Ñ.Ü2Ø(Ð):Ð(;Ð;MÐNóðô"Ð"3×4Ó4Ü2Ø(Ð):Ð(;ð<+ð+óðò :rc ó•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Úfuturers rÚ on_queuedÚBaseSubscriber.on_queued0ó€ð rc ó•g)aCallback 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_transferredrs rÚ on_progressÚBaseSubscriber.on_progress?s€ð rc ó•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_doneQr&rr )Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__rrÚ classmethodrr r$r)r,Ú__static_attributes__Ú __classcell__)rs@rrrsEø†ñò <Ðõ$ðØñ óóð ò  ò ÷$  ð  rrN)Ú functoolsrÚs3transfer.compatrÚs3transfer.exceptionsrrr rrÚr9sðõ å,Ý>÷K òK r