^f)ldZddlmZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z mZddlmZmZddlmZd d lmZd ZeZGd d ZGddeZddefdZGddZdZe efe ffdZe effdZ d&dZ!dZ"d'dZ#d(dZ$ d)dZ%d*d"Z&d+d$Z'd%Z(eZ)eZ*dS),zFunctional Utilities.) annotationsN) OrderedDictUserDict)IterableMapping)countrepeat)sleeptime)wraps) safe_repr)LRUCachememoizelazymaybe_evaluateis_list maybe_list dictfilterretry_over_timec eZdZdZdZdZdS)ChannelPromisec||_dSN) __contract__)selfcontracts H/var/www/html/env/lib/python3.11/site-packages/kombu/utils/functional.py__init__zChannelPromise.__init__s$cl |jS#t$r |x}|_|cYSwxYwr) __value__AttributeErrorr)rvalues r__call__zChannelPromise.__call__sK > !   %)%6%6%8%8 8EDNLLL s  '33c~ t|jS#t$rdt|jddcYSwxYw)Nz )reprr"r#idrrs r__repr__zChannelPromise.__repr__%sW ='' ' = = =<"T%6"7"7<<<< < < < =s #<<N)__name__ __module__ __qualname__rr%r,r rrrsA%%%=====r rcxeZdZdZddZdZdZddZdZd Z d Z e Z d Z e Z d ZeZddZdZdZeZe Ze ZdS)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. Ncj||_tj|_t |_dSr)limit threadingRLockmutexrdata)rr3s rrzLRUCache.__init__7s' _&& MM r c|j5|j|x}||<|cdddS#1swxYwYdSr)r6r7poprkeyr$s r __getitem__zLRUCache.__getitem__<s Z   $ c 2 2 2EDI                  s !6::c|j5|j|j}}|j|i||rKt ||kr8t t ||z D]}|dddddS#1swxYwYdS)NF)last)r6r7r3updatelenrangepopitem)rargskwargsr7r3_s rr?zLRUCache.updateAs Z - -)TZ%D DK ( ( ( ( -TU**s4yy5011--ALLeL,,,,  - - - - - - - - - - - - - - - - - -sA)A>>BBTcx|j5|j|cdddS#1swxYwYdSr)r6r7rB)rr>s rrBzLRUCache.popitemJs Z + +9$$T** + + + + + + + + + + + + + + + + + +s /33c|j5|jrVt|j|jkr9|jt t |j||j|<ddddS#1swxYwYdSr)r6r3r@r7r9nextiterr:s r __setitem__zLRUCache.__setitem__Ns Z # #z 5c$)nn :: d4 ??33444"DIcN # # # # # # # # # # # # # # # # # #sA(A==BBc*t|jSr)rIr7r+s r__iter__zLRUCache.__iter__UsDIr c#K|j5|D]$} ||j|fV#t$rY!wxYw ddddS#1swxYwYdSrr6r7KeyErrorrks r_iterate_itemszLRUCache._iterate_itemsXs Z    dil+++++D                   s,A"A /A/AAAc#K|j5|D]"} |j|V#t$rYwxYw ddddS#1swxYwYdSrrNrPs r_iterate_valueszLRUCache._iterate_valuesas Z    )A,&&&&D                   s'> > ->->AAcv|j5|jcdddS#1swxYwYdSr)r6r7keysr+s r _iterate_keyszLRUCache._iterate_keysks} Z $ $9>>## $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s .22r c|j5t|j||z}t |||<|cdddS#1swxYwYdSr)r6intr7r9str)rr;deltanewvals rincrz LRUCache.incrqs Z  s++,,u4FF DI                   s>AAAchtt|}|d|S)Nr6)dictvarsr9)rds r __getstate__zLRUCache.__getstate__ys) d   gr cD||_tj|_dSr)__dict__r4r5r6)rstates r __setstate__zLRUCache.__setstate__~s _&& r r)T)r )r-r.r/__doc__rr<r?rBrJrLrR iteritemsrT itervaluesrWiterkeysr]rbrfrVvaluesitemsr0r rrr,s""""  ---++++###I!J$$$H ''' D F EEEr rcfd}|S)z)Decorator to cache function return value.ctjtfdfd}dx__|__S)N)r3cr ||}n:|tfztt|z} 5|}dddn #1swxYwYxjdz c_nG#t $r:|i|}xjdz c_5||<dddn #1swxYwYYnwxYw|S)Nr ) KEYWORD_MARKtuplesortedrlhitsrOmisses) rCrDr;r$_Mcachefunkeyfunr6s rruz%memoize.._memoize.._Msq MfT6**l_,uVFLLNN5K5K/L/LL ''!#JE'''''''''''''''1   ' ' 'T,V,, Q ''!&E#J''''''''''''''' 'LsZ A? A# A?#A''A?*A'+A??$C#B5) C5B9 9C<B9 =CCcLdx__dS)z+Clear the cache and reset cache statistics.rN)clearrsrt)rurvsrrzz(memoize.._memoize..clears" KKMMM"# #BGbiiir r)r4Lockr rsrtrz original_func)rwrzrurvr6Cacherxmaxsizes` @@@r_memoizezmemoize.._memoizes  G$$$ s          " $ $ $ $ $ $  ") r r0)r~rxr}rs``` rrrs0@ Or cHeZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) 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__`. c0||_||_||_dSr_fun_args_kwargs)rrwrCrDs rrz lazy.__init__s   r c*|Sr)evaluater+s rr%z lazy.__call__s}}r c0|j|ji|jSrrr+s rrz lazy.evaluatesty$*5 555r c0t|Sr)rZr+s r__str__z lazy.__str__s4466{{r c0t|Sr)r)r+s rr,z lazy.__repr__sDDFF||r c||kSrr0rrhss r__eq__z lazy.__eq__tvv}r c||kSrr0rs r__ne__z lazy.__ne__rr c*||t|<|Sr)r*)rmemos r __deepcopy__zlazy.__deepcopy__sRXX r c<|j|jf|j|jdfS)N)rr) __class__rrrr+s r __reduce__zlazy.__reduce__s.  :>,/H/HI Ir N) r-r.r/rgrr%rrr,rrrrr0r rrrs 666IIIIIr rcXt|tr|S|S)z9Evaluate value only if value is a :class:`lazy` instance.) isinstancerr)r$s rrrs)% ~~ Lr cHt||ot||pd 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*H&HHr c0|t||r|n|gS)z0Return list of one element if ``l`` is a scalar.)r)rrs rrrs +g!6!6+33SEAr c h||n|r t|fi|n|}d|DS)z=Remove all keys from dict ``d`` whose value is :const:`None`.Nci|] \}}||| Srr0).0rQvs r zdictfilter..s 8 8 8TQ!-Aq---r )r_rl)rakws rrrs@ir8d1mmmmmqA 8 8QWWYY 8 8 88r c#Kt|}tj}tdD]}|||dVdS)Nr)listrandomshuffler )itrrEs r shufflecyclersS bBnG D\\ e r ?Fc#NK|dz} |r||kr |V||z }n |sdS||z V)Nrr0)startstopstep repeatlastcurs rfxrangersZ #+C sd{{III 4KCC *   r Y@c#pKd|dz}} ||krdS|V|rt||z|}n||z }||z }-)Nrr)min)rrrmaxsum_rs r fxrangemaxrsc53;#D 3;; E  cDj$''CC 4KC  r c H|sin|}|sgn|}t|||z|d} | rt| znd} tD]} ||i|cS#|$r}|| |kr| rt| kr| r | t|r ||| | nt | }|rft t |D]}| r | tdttt ||z Yd}~d}~wwxYwdS)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 rrrsF )RR6F #22tD^)N:*t===N& /$&&7  4C77++ +3''' ' ' ' + + +&7k+A+A tvv||  2^W===!.1133C +s3xxA#  #JJJJc#c((S.))*** +++s ADB=DD, {0}={1}cj|fd|DS)Nc3dK|]*\}}|t|V+dSr)format _safe_repr)rrQrfmts r zreprkwargs..Rs;LLTQCJJq*Q--00LLLLLLr )joinrl)rDseprs `r reprkwargsrQs2 88LLLLV\\^^LLL L LLr r0c |sin|}d||tt|pd|r|r|pdt ||S)Nz {}({}{}{})r0)rrmaprr)namerCrDrs rreprcallrUse )RR6F    chhs:tzr2233 &!c'R63  r cNtj|}||jvp||jvSr)inspectgetfullargspecrC kwonlyargs)func argument_name argument_specs raccepts_argumentr^s2*400M++ 211r r)rNrF)rNrr) NNNNrrrNN)rr)r0Nr)+rg __future__rrrr4 collectionsrrcollections.abcrr itertoolsrr r r vine.utilsr encodingrr__all__objectrprrrrrrZrrrrrrrrrrpromise maybe_promiser0r rrs"""""" ----------------########------  vxx ========&XXXXXxXXXvX""""J'I'I'I'I'I'I'I'IT"3{IIII%cNBBBB 9999         AEFG<@;+;+;+;+|MMMM  r