B f 8HdZddlZddlZddlmZddlmZddlm Z ddlm Z Gdde Z ej e ejejejejZeje Zej e Zejed d d d ZGdde jZdS)z5Abstract and helper bases for Future implementations.N) exceptionsretry)_helpers)baseceZdZdZdS)_OperationNotCompletez-Private exception used for polling via retry.N)__name__ __module__ __qualname____doc__m/home/panchajanya/Development/work/volatility3/lib/python3.11/site-packages/google/api_core/future/polling.pyr r s77Drr ) predicateg?g4@g?i)rinitialmaximum multipliertimeoutceZdZdZeZeffd Zej ddZ ddZ dZ eddfdZ eddfdZefd Zd Zd Zd Zd ZxZS) PollingFutureaA Future that needs to poll some service to check its status. The :meth:`done` method should be implemented by subclasses. The polling behavior will repeatedly call ``done`` until it returns True. The actual polling logic is encapsulated in :meth:`result` method. See documentation for that method for details on how polling works. .. note:: Privacy here is intended to prevent the final class from overexposing, not to prevent subclasses from accessing methods. Args: polling (google.api_core.retry.Retry): The configuration used for polling. This parameter controls how often :meth:`done` is polled. If the ``timeout`` argument is specified in :meth:`result` method it will override the ``polling.timeout`` property. retry (google.api_core.retry.Retry): DEPRECATED use ``polling`` instead. If set, it will override ``polling`` parameter for backward compatibility. c tt||d||_d|_d|_d|_ d|_g|_ dS)NrF) superr__init__get_polling_result _exception _result_set_polling_thread_done_callbacks)selfpollingkwargs __class__s rrzPollingFuture.__init__[se mT""++--- 7G44    #!rNct)a{Checks to see if the operation is complete. Args: retry (google.api_core.retry.Retry): (Optional) How to retry the polling RPC (to not be confused with polling configuration. See the documentation for :meth:`result` for details). Returns: bool: True if the operation is complete, False otherwise. )NotImplementedErrorr"rs rdonezPollingFuture.donefs"###rcN||stdS)z2Check if the future is done and raise if it's not.rN)r)r r(s r_done_or_raisezPollingFuture._done_or_raiseus.yyuy%% *')) ) * *rc,| S)z+True if the operation is currently running.)r))r"s rrunningzPollingFuture.runningzs99;;rc|jrdS|p|j}|tjur||} ||j|dS#t j$r)tj d|j dwxYw)z,Poll and wait for the Future to be resolved.Nrzr^s^<; &&&&&&,,,,,,++++++''''''     I   ,'+"!  888 .G-  '-    B%B%B%B%B%DKB%B%B%B%B%r