U be+@s,dZddlmZddZGdddeZdS)z5 Module containing the RetryingClient wrapper class. )sleepcCsT|dkrtSt|tttfs*td|t|}tdd|DsPtd||S)aV Helper function to ensure the given arguments are tuples of Exceptions (or subclasses), or can at least be converted to such. Args: argument_name: str, name of the argument we're checking, only used for raising meaningful exceptions. argument: any, the argument itself. Returns: tuple[Exception]: A tuple with the elements from the argument if they are valid. Exceptions: ValueError: If the argument was not None, tuple or Iterable. ValueError: If any of the elements of the argument is not a subclass of Exception. Nz+%s must be either a tuple, a set or a list.cSsg|]}t|tqS) issubclass Exception).0argrr\/var/www/html/services/stratfitenv/lib/python3.8/site-packages/pymemcache/client/retrying.py %sz*_ensure_tuple_argument..zH%s is only allowed to contain elements that are subclasses of Exception.)tuple isinstancesetlist ValueErrorall) argument_nameZargument_valueZargument_tuplerrr_ensure_tuple_arguments rc@sJeZdZdZdddZddZd d Zd d Zd dZddZ ddZ dS)RetryingClientzB Client that allows retrying calls for the other clients. rNcCsp|dkrtd||_||_||_td||_td||_|jD]}||jkr@tdt|q@t|j|_ dS)a Constructor for RetryingClient. Args: client: Client|PooledClient|HashClient, inner client to use for performing actual work. attempts: optional int, how many times to attempt an action before failing. Must be 1 or above. Defaults to 2. retry_delay: optional int|float, how many seconds to sleep between each attempt. Defaults to 0. retry_for: optional None|tuple|set|list, what exceptions to allow retries for. Will allow retries for all exceptions if None. Example: `(MemcacheClientError, MemcacheUnexpectedCloseError)` Accepts any class that is a subclass of Exception. Defaults to None. do_not_retry_for: optional None|tuple|set|list, what exceptions should be retried. Will not block retries for any Exception if None. Example: `(IOError, MemcacheIllegalInputError)` Accepts any class that is a subclass of Exception. Defaults to None. Exceptions: ValueError: If `attempts` is not 1 or above. ValueError: If `retry_for` or `do_not_retry_for` is not None, tuple or Iterable. ValueError: If any of the elements of `retry_for` or `do_not_retry_for` is not a subclass of Exception. ValueError: If there is any overlap between `retry_for` and `do_not_retry_for`. zG`attempts` argument must be at least 1. Otherwise no attempts are made. retry_fordo_not_retry_forzException class "%s" was present in both `retry_for` and `do_not_retry_for`. Any exception class is only allowed in a single argument.N) r_client _attempts _retry_delayr _retry_for_do_not_retry_forreprdir _client_dir)selfclientZattemptsZ retry_delayrr exc_classrrr__init__3s((   zRetryingClient.__init__c Ost|jD]}z|||}|WStk r}zN||jdksp|jrTt||jrp|jrft||jsp||jkrt|t|jW5d}~XYq Xq dS)a3 Workhorse function, handles retry logic. Args: name: str, Name of the function called. func: callable, the function to retry. *args: args, array arguments to pass to the function. **kwargs: kwargs, keyword arguments to pass to the function. rN) rangerrrr rrrr)rnamefuncargskwargsattemptresultexcrrr_retryus&       zRetryingClient._retrycsfddS)Ncsjjf||SN)r+r__getattribute__)r&r'r$rrrs z,RetryingClient.__getattr__..r)rr$rr.r __getattr__szRetryingClient.__getattr__cCs|jSr,)r)rrrr__dir__szRetryingClient.__dir__cCs|j||dddSNT)Znoreply)r rkeyvaluerrr __setitem__szRetryingClient.__setitem__cCs||}|dkrt|Sr,)getKeyErrorr3rrr __getitem__s zRetryingClient.__getitem__cCs|j|dddSr2)delete)rr4rrr __delitem__szRetryingClient.__delitem__)rrNN) __name__ __module__ __qualname____doc__r"r+r0r1r6r9r;rrrrr.s B& rN)r?timerrobjectrrrrrs (