o wvXj0-@sdZddlmZmZddlZddlZddlZddlZddlm Z z ddl m Z m Z Wne y;ddlm Z m Z YnwddlmZmZddlmZmZddlmZdd lmZmZmZmZmZmZd d lmZd Ze Z!eGd dde Z"GdddeZ#dde#fddZ$eGddde Z%ddZ&e efe ffddZ'e effddZ(d3ddZ)ddZ*d4d!d"Z+d5d$d%Z,  & d6d(d)Z-d7d,d-Z.d8d/d0Z/d1d2Z0e%Z1e&Z2dS)9zFunctional Utilities.)absolute_importunicode_literalsN) OrderedDict)IterableMapping)countrepeat)sleeptime)wraps)UserDictitemskeyspython_2_unicode_compatiblestring_tPY3) safe_repr)LRUCachememoizelazymaybe_evaluateis_list maybe_list dictfilterc@s$eZdZddZddZddZdS)ChannelPromisecCs ||_dSN) __contract__)selfcontractr S/var/www/html/myproject/venv/lib/python3.10/site-packages/kombu/utils/functional.py__init__& zChannelPromise.__init__cCs.z|jWSty|}|_|YSwr) __value__AttributeErrorr)rvaluer r r!__call__)s  zChannelPromise.__call__cCs0zt|jWStydt|jYSw)Nz)reprr$r%formatidrrr r r!__repr__0s   zChannelPromise.__repr__N)__name__ __module__ __qualname__r"r'r,r r r r!r#s rc@seZdZdZd%ddZddZddZd&d d Zd d ZddZ ddZ e Z ddZ e Z ddZeZd'ddZddZddZejddkrNeZe Ze ZdSdd Zd!d"Zd#d$ZdS)(ra?LRU Cache implementation using a doubly linked list to track access. Arguments: limit (int): The maximum number of keys to keep in the cache. When a new key is inserted and the limit has been exceeded, the *Least Recently Used* key will be discarded from the cache. NcCs||_t|_t|_dSr)limit threadingRLockmutexrdata)rr0r r r!r"As  zLRUCache.__init__cCsB|j|j|}||<|WdS1swYdSr)r3r4poprkeyr&r r r! __getitem__Fs$zLRUCache.__getitem__cOs|jA|j|j}}|j|i||r,t||kr4tt||D]}|jddq#WddSWddSWddS1sGwYdS)NF)last)r3r4r0updatelenrangepopitem)rargskwargsr4r0_r r r!r:Ks"zLRUCache.updateTcCs6|j|j|WdS1swYdSr)r3r4r=)rr9r r r!r=Ts $zLRUCache.popitemcCsb|j$|jrt|j|jkr|jtt|j||j|<WddS1s*wYdSr)r3r0r;r4r5nextiterr6r r r! __setitem__Xs  "zLRUCache.__setitem__cCs t|jSr)rBr4r+r r r!__iter___r#zLRUCache.__iter__c cs^|j!|D]}z ||j|fVWqtyYqwWddS1s(wYdSrr3r4KeyErrorrkr r r!_iterate_itemsbs "zLRUCache._iterate_itemsc csZ|j|D]}z|j|VWqtyYqwWddS1s&wYdSrrErGr r r!_iterate_valuesks "zLRUCache._iterate_valuescCs4|j t|jWdS1swYdSr)r3rr4r+r r r! _iterate_keysus$zLRUCache._iterate_keysrcCsN|jt|j||}t|||<|WdS1s wYdSr)r3intr4r5str)rr7deltanewvalr r r!incr{s  $z LRUCache.incrcCstt|}|d|S)Nr3)dictvarsr5)rdr r r! __getstate__s  zLRUCache.__getstate__cCs||_t|_dSr)__dict__r1r2r3)rstater r r! __setstate__szLRUCache.__setstate__rcC t|Sr)listrKr+r r r!r z LRUCache.keyscCrYr)rZrJr+r r r!valuesr[zLRUCache.valuescCrYr)rZrIr+r r r!r r[zLRUCache.itemsr)T)r)r-r.r/__doc__r"r8r:r=rCrDrI iteritemsrJ itervaluesrKiterkeysrPrTrWsys version_inforr\r r r r r!r7s0    rcsfdd}|S)z)Decorator to cache function return value.csXtdtfddfdd}d__|__S)N)r0c sr||}n |tftt|}z |}Wdn1s'wYWn0ty]|i|}jd7_||<WdY|S1sUwYY|Swjd7_|S)Nr) KEYWORD_MARKtuplesortedr rFmisseshits)r>r?r7r&)_Mcachefunkeyfunr3r r!rhs(     z%memoize.._memoize.._Mcsd__dS)z+Clear the cache and reset cache statistics.rN)clearrgrfr )rhrir r!rlsz(memoize.._memoize..clearr)r1Lockr rgrfrl original_func)rjrlCacherkmaxsize)rhrirjr3r!_memoizes  zmemoize.._memoizer )rqrkrprrr ror!rs rc@sreZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ e jddkr7ddZdSdS)ra Holds lazy evaluation. Evaluated when called or if the :meth:`evaluate` method is called. The function is re-evaluated on every call. Overloaded operations that will evaluate the promise: :meth:`__str__`, :meth:`__repr__`, :meth:`__cmp__`. cOs||_||_||_dSr_fun_args_kwargs)rrjr>r?r r r!r"s z lazy.__init__cCs|Sr)evaluater+r r r!r'sz lazy.__call__cCs|j|ji|jSrrsr+r r r!rwsz lazy.evaluatecC t|Sr)rMr+r r r!__str__r#z lazy.__str__cCrxr)r(r+r r r!r,r#z lazy.__repr__cCs ||kSrr rrhsr r r!__eq__r#z lazy.__eq__cCs ||kSrr rzr r r!__ne__r#z lazy.__ne__cCs||t|<|Sr)r*)rmemor r r! __deepcopy__s zlazy.__deepcopy__cCs|j|jf|j|jdfS)N)rurv) __class__rtrurvr+r r r! __reduce__szlazy.__reduce__rrXcCs&t||jr t|| St||Sr) isinstancercmprzr r r!__cmp__s  z lazy.__cmp__N)r-r.r/r]r"r'rwryr,r|r}rrrarbrr r r r!rs  rcCst|tr |S|S)z9Evaluate value only if value is a :class:`lazy` instance.)rrrw)r&r r r!rs rcCst||o t||p d S)znReturn true if the object is iterable. Note: Returns false if object is a mapping or string. r )r)objscalarsitersr r r!rsrcCs|dus t||r |S|gS)z0Return list of one element if ``l`` is a scalar.N)r)rrr r r!rsrcKs6|dur|n |rt|fi|n|}ddt|DS)z=Remove all keys from dict ``d`` whose value is :const:`None`.NcSsi|] \}}|dur||qSrr .0rHvr r r! szdictfilter..)rQr )rSkwr r r!rs$rccs4t|}tj}tdD] }|||dVq dS)Nr)rZrandomshuffler)itrr@r r r! shufflecycles  r?Fccs<|d} |r ||kr|V||7}n |sdS||Vq)Nrr )startstopstep repeatlastcurr r r!fxranges   rY@ccsJd|d}} ||krdS|V|rt|||}n||7}||7}q )Nrr)min)rrrmaxsum_rr r r! fxrangemax"src  Cs |sin|}|s gn|}t||||dd} | rt| nd} tD]`} z ||i|WS|y}zH|dur?| |kr?| rGt| krG| rL| t|rU||| | nt| }|rxtt|D] }| ri| tdqbttt||WYd}~q"d}~wwdS)aRetry the function over and over until max retries is exceeded. For each retry we sleep a for a while before we try again, this interval is increased for every retry until the max seconds is reached. Arguments: fun (Callable): The function to try catch (Tuple[BaseException]): Exceptions to catch, can be either tuple or a single exception class. Keyword Arguments: args (Tuple): Positional arguments passed on to the function. kwargs (Dict): Keyword arguments passed on to the function. errback (Callable): Callback for when an exception in ``catch`` is raised. The callback must take three arguments: ``exc``, ``interval_range`` and ``retries``, where ``exc`` is the exception instance, ``interval_range`` is an iterator which return the time in seconds to sleep next, and ``retries`` is the number of previous retries. max_retries (int): Maximum number of retries before we give up. If neither of this and timeout is set, we will retry forever. If one of this and timeout is reached, stop. interval_start (float): How long (in seconds) we start sleeping between retries. interval_step (float): By how much the interval is increased for each retry. interval_max (float): Maximum number of seconds to sleep between retries. timeout (int): Maximum seconds waiting before we give up. T)rNr) rr rfloatrAr<rLr abs)rjcatchr>r?errback max_retriesinterval_start interval_step interval_maxcallbacktimeoutinterval_rangeendretriesexcttsr@r r r!retry_over_time/s: !   r, {0}={1}cs|fddt|DS)Nc3s$|] \}}|t|VqdSr)r) _safe_reprrfmtr r! ls"zreprkwargs..)joinr )r?seprr rr! reprkwargsksrr cCs>|sin|}d||tt|pd|r|r|pdt||S)Nz{0}({1}{2}{3})r )r)rmaprr)namer>r?rr r r!reprcallos rcCs:trt|}||jvp||jvSt|}|j}||vSr)rinspectgetfullargspecr> kwonlyargs getargspec)func argument_name argument_specargument_namesr r r!accepts_argumentxs   rr)rNrF)rNrr) NNNNrrrNN)rr)r Nr)3r] __future__rrrrar1r collectionsrcollections.abcrr ImportError itertoolsrrr r vine.utilsr kombu.fiver r rrrrencodingrr__all__objectrcrrrrrrrrrrrrrrrpromise maybe_promiser r r r!sR     e%1     <