Ih)RdZddlmZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z mZddlmZmZddlmZd d lmZd ZeZGd d ZGddeZddefdZGddZdZe efe ffdZe effdZ ddZ!dZ"ddZ#d dZ$ d!dZ%d"dZ&d#dZ'dZ(eZ)eZ*y)$zFunctional Utilities.) annotationsN) OrderedDictUserDict)IterableMapping)countrepeat)sleeptime)wraps) safe_repr)LRUCachememoizelazymaybe_evaluateis_list maybe_list dictfilterretry_over_timeceZdZdZdZdZy)ChannelPromisec||_yN) __contract__)selfcontracts O/var/www/html/planif/env/lib/python3.12/site-packages/kombu/utils/functional.py__init__zChannelPromise.__init__s $cl |jS#t$r|jx}|_|cYSwxYwr) __value__AttributeErrorr)rvalues r__call__zChannelPromise.__call__s: >> ! %)%6%6%8 8EDNL s "33c t|jS#t$rdt|jddcYSwxYw)Nz )reprr"r#idrrs r__repr__zChannelPromise.__repr__%sB =' ' =!"T%6%6"7!:!< < =s #==N)__name__ __module__ __qualname__rr%r,r rrrs%=r rcveZdZdZddZdZdZddZdZdZ d Z e Z d Z e Z d ZeZdd Zd ZdZeZe Ze Zy)raMLRU 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. Ncb||_tj|_t |_yr)limit threadingRLockmutexrdata)rr3s rrzLRUCache.__init__7s  __& M r c|j5|jj|x}||<|cdddS#1swYyxYwr)r6r7poprkeyr$s r __getitem__zLRUCache.__getitem__<s< ZZ  $ c 2 2EDI   s "9Ac|j5|j|j}}|j|i||rs rrBzLRUCache.popitemJs0 ZZ +99$$T* + + +s2;c.|j5|jrYt|j|jk\r7|jj t t |j||j|<dddy#1swYyxYwr)r6r3r@r7r9nextiterr:s r __setitem__zLRUCache.__setitem__Nsb ZZ #zzc$))n : d4 ?34"DIIcN # # #s A5B  Bc,t|jSr)rIr7r+s r__iter__zLRUCache.__iter__UsDIIr c#K|j5|D]} ||j|f dddy#t$rY.wxYw#1swYyxYwwrr6r7KeyErrorrks r_iterate_itemszLRUCache._iterate_itemsXsa ZZ  diil++       s: AA5A A AAAAA  Ac#K|j5|D]} |j| dddy#t$rY,wxYw#1swYyxYwwrrNrPs r_iterate_valueszLRUCache._iterate_valuesas\ ZZ  ))A,&       s6 AA3A A ?A?AA Acz|j5|jjcdddS#1swYyxYwr)r6r7keysr+s r _iterate_keyszLRUCache._iterate_keysks, ZZ $99>># $ $ $s1:c|j5t|jj||z}t |||<|cdddS#1swYyxYwr)r6intr7r9str)rr;deltanewvals rincrz LRUCache.incrqsL ZZ s+,u4FF DI    s 7AAcPtt|}|jd|S)Nr6)dictvarsr9)rds r __getstate__zLRUCache.__getstate__ys d  gr cD||_tj|_yr)__dict__r4r5r6)rstates r __setstate__zLRUCache.__setstate__~s __& r r)T)r )r-r.r/__doc__rr<r?rBrJrLrR iteritemsrT itervaluesrWiterkeysr]rbrfrVvaluesitemsr0r rrr,si"  -+#I!J$H ' D F Er rcfd}|S)z)Decorator to cache function return value.ctjtfdfd}dx__|__S)N)r3ctr ||}n-|tfztt|jz} 5|}dddxjdz c_S#1swY xYw#t $r?|i|}xj dz c_5||<dddY|S#1swYY|SxYwwxYw)Nr ) KEYWORD_MARKtuplesortedrlhitsrOmisses) rCrDr;r$_Mcachefunkeyfunr6s rruz%memoize.._memoize.._MsT6*l_,uVFLLN5K/LL '!#JE'1 L'' 'T,V, Q '!&E#J''L ''L 's@A/A#A/#A,(A//(B7B(B7(B3 -B73B7cBjdx__y)z+Clear the cache and reset cache statistics.rN)clearrsrt)rurvsrrzz(memoize.._memoize..clears KKM"# #BGbir r)r4Lockr rsrtrz original_func)rwrzrurvr6Cacherxmaxsizes` @@@r_memoizezmemoize.._memoizesX G$ s   " $  ") r r0)r~rxr}rs``` rrrs@ Or cFeZdZdZdZdZdZdZdZdZ dZ d Z d Z y ) 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__`. c.||_||_||_yr_fun_args_kwargs)rrwrCrDs rrz lazy.__init__s   r c"|jSr)evaluater+s rr%z lazy.__call__s}}r cN|j|ji|jSrrr+s rrz lazy.evaluates tyy$**5 55r c"t|Sr)rZr+s r__str__z lazy.__str__s46{r c"t|Sr)r)r+s rr,z lazy.__repr__sDF|r c||k(Srr0rrhss r__eq__z lazy.__eq__v}r c||k7Srr0rs r__ne__z lazy.__ne__rr c"||t|<|Sr)r*)rmemos r __deepcopy__zlazy.__deepcopy__sRX r cd|j|jf|j|jdfS)N)rr) __class__rrrr+s r __reduce__zlazy.__reduce__s0  :>,,/HI Ir N) r-r.r/rgrr%rrr,rrrrr0r rrrs5 6Ir rcFt|tr|jS|S)z9Evaluate value only if value is a :class:`lazy` instance.) isinstancerr)r$s rrrs%~~ Lr c@t||xrt||xsd S)zwReturn true if the object is iterable. Note: ---- Returns false if object is a mapping or string. r0)r)objscalarsiterss rrrs$ c5 ! H*S'-R*H&HHr c(| t||r|S|gS)z0Return list of one element if ``l`` is a scalar.)r)rrs rrrs+g!63ASEAr c ||n|r t|fi|n|}|jDcic] \}}| || c}}Scc}}w)z=Remove all keys from dict ``d`` whose value is :const:`None`.)r_rl)rakwrQvs rrrs?ird1mmqAWWY 8TQ!-AqD 88 8s <<c#Kt|}tj}tdD]}|||dyw)Nr)listrandomshuffler )itrrEs r shufflecyclers; bBnnG D\ e s<>c#NK|dz} |r||kr |||z }n |sy||z w)N?r0)startstopstep repeatlastcurs rfxrangers> #+C sd{I 4KC*  s#%c#hKd|dz}} ||k\ry||rt||z|}n||z }||z }'w)Nrr)min)rrrmaxsum_rs r fxrangemaxrsO53;#D 3;  cDj$'C 4KC   s02c |sin|}|sgn|}t|||z|d} | r t| znd} tD] } ||i|cSy#|$r}|| |k\r| rt| kDr| r| t|r ||| | n t | }|rMt t |D]}| r| tdttt ||z Yd}~d}~wwxYw)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 rfloatrHrArYr abs)rwcatchrCrDerrback max_retriesinterval_start interval_step interval_maxcallbacktimeoutinterval_rangeendretriesexcttsrEs rrrsFR6F2tD^)N:*t=N&$&7 4C7+ +'' '+ +&7k+Atv| ^W=!.13Cs3xA #J c#c(S.)* +sA  C)BC$$C)cT|jfd|jDS)Nc3ZK|]"\}}j|t|$ywr)format _safe_repr).0rQrfmts r zreprkwargs..Rs$LTQCJJq*Q-0Ls(+)joinrl)rDseprs `r reprkwargsrQs 88LV\\^L LLr c |sin|}dj||jtt|xsd|xr|xr|xsdt ||S)Nz {}({}{}{})r0)rrmaprr)namerCrDrs rreprcallrUsRR6F    chhs:tzr23 &!c'R63 r chtj|}||jvxs||jvSr)inspectgetfullargspecrC kwonlyargs)func argument_name argument_specs raccepts_argumentr^s8**40M+++ 2111r r)rNrF)rNrgY@) NNNNrNN), z{0}={1})r0Nr)+rg __future__rrrr4 collectionsrrcollections.abcrr itertoolsrr r r vine.utilsr encodingrr__all__objectrprrrrrrZrrrrrrrrrrpromise maybe_promiser0r rrs" --#-  x ==&XxXvX"J'I'IT"3{I%cNB 9   AEFG<@;+|M  r