,>SSKJr SSKJr SSKJr "SS\5rg))six)accepts_kwargs)InvalidSubscriberMethodErrorcV^\rSrSrSr/SQrU4Sjr\S5rSr Sr Sr S r U=r $) BaseSubscriberzThe base subscriber class It is recommended that all subscriber implementations subclass and then override the subscription methods (i.e. on_{subsribe_type}() methods). )queuedprogressdonecJ>UR5 [[U]U5$)N)_validate_subscriber_methodssuperr__new__)clsargskwargs __class__s )lib/third_party/s3transfer/subscribers.pyrBaseSubscriber.__new__s! ((*^S1#66cURHYn[USU-5n[R"U5(d[ SU-5e[ U5(aMM[ SU-5e g)Non_z&Subscriber method %s must be callable.z=Subscriber method %s must accept keyword arguments (**kwargs))VALID_SUBSCRIBER_TYPESgetattrrcallablerr)rsubscriber_typesubscriber_methods rr +BaseSubscriber._validate_subscriber_methods#sv"99O 'U_-D E << 1222<%&''""3442+->?@@ :rc g)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. Nselffuturers r on_queuedBaseSubscriber.on_queued1 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_progressBaseSubscriber.on_progress@s rc g)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. Nr r!s ron_doneBaseSubscriber.on_doneRr&rr )__name__ __module__ __qualname____firstlineno____doc__rr classmethodr r$r)r,__static_attributes__ __classcell__)rs@rrrs?  7 @ @   $   rrN)botocore.compatrs3transfer.compatrs3transfer.exceptionsrobjectrr rrr:s ,>L VL r