hXcjdZddlZddlmZddlmZddlmZmZm Z m Z m Z ddl m Z mZmZddlmZmZddlmZdd lmZmZmZmZd d lmZmZd d lmZ dd lm Z! ddl#m$Z$m%Z%dZ&dZ'dZ(dZ)GddeZGddZ*Gdde+e*Z,GddZ-e j\e-Gdde Z/Gdd e/e*Z0Gd!d"Z1e j\e1Gd#d$Z2Gd%d&e2Z3e j\e3Gd'd(ee2Z4y#e"$rdZ!YwxYw#e"$rGddZ$e$Z%YwxYw))z8Custom maps, sets, sequences, and other data structures.N) OrderedDict)deque)CallableMappingMutableMapping MutableSetSequence)heapifyheappopheappush)chaincount)Empty)AnyDictIterableList)firstuniq) match_case) reversed_dict) LazyObject LazySettingsc eZdZy)rN)__name__ __module__ __qualname__T/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/utils/collections.pyrrs r r) AttributeDictMixin AttributeDict BufferMapChainMapConfigurationView DictAttribute Evictable LimitedSet Messagebufferr force_mappinglpmergezK<{name}({size}): maxlen={0.maxlen}, expires={0.expires}, minlen={0.minlen}>ct|ttfr |j}t|ts t |S|S)z?Wrap object into supporting the mapping interface if necessary.) isinstancerr_wrappedrr')ms r!r+r+'s5!j,/0 JJ#-a#9= @q@r c|j}|jDcgc]\}}| |||c}}|Scc}}w)zpIn place left precedent dictionary merge. Keeps values from `L`, if the value in `R` is :const:`None`. ) __setitem__items)LRsetitemkvs r!r,r,/s9 mmG wwy:tq!AMWQ]: H;s < <c@eZdZdZdZeeds erddZyddZyy)rz#Dict where insertion order matters.cFtt|jSN)nextiterkeysselfs r!_LRUkeyzOrderedDict._LRUkey=sD%&&r move_to_endcF|s td|j|||<y)Nzno last=True on PyPy)NotImplementedErrorpop)r@keylasts r!rBzOrderedDict.move_to_endFs$..DEE HHSMS r c|j|}|d}|d}||d<||d<|j}|r|d}||d<||d<|x|d<|d<y|d}||d<||d<|x|d<|d<yNrr)_OrderedDict__map_OrderedDict__root)r@rFrGlink link_prev link_nextroot first_nodes r!rBzOrderedDict.move_to_endQs--c2 G  G ( ! ( ! ..7D"DG"DG(,,DGd1g!%aJ"DG(DG.22DGjmr N)T) rrr__doc__rAhasattr _OrderedDict_dict_is_orderedrBrr r!rr:s(-' < /  * 3 0r rc&eZdZdZdZdeddfdZy)r"z[Mixin for Mapping interface that adds attribute access. I.e., `d.key -> d[key]`). cn ||S#t$r$tt|jd|wxYw)z`d.key -> d[key]`.z object has no attribute )KeyErrorAttributeErrortyper)r@r7s r! __getattr__zAttributeDictMixin.__getattr__ksK J7N J :&&))B1%HJ J Js-4rFreturnNc|||<y)z"`d[key] = value -> d.key = value`.Nrr@rFvalues r! __setattr__zAttributeDictMixin.__setattr__ts S r )rrrrQrZstrr_rr r!r"r"es  Jsdr r"ceZdZdZy)r#z$Dict subclass with attribute access.N)rrrrQrr r!r#r#ys.r r#cxeZdZdZdZdZdZdZddZddZ dZ d Z d Z d Z e Zd Zd ZeZdZeZeZe ZeZy)r'z[Dict interface to attributes. `obj[k] -> obj.k` `obj[k] = val -> obj.k = val` Nc2tj|d|y)Nobj)objectr_)r@rds r!__init__zDictAttribute.__init__s4,r c.t|j|Sr;)getattrrdr@rFs r!rZzDictAttribute.__getattr__txx%%r c0t|j||Sr;setattrrdr]s r!r_zDictAttribute.__setattr__stxxe,,r c0 ||S#t$r|cYSwxYwr;rWr@rFdefaults r!getzDictAttribute.get% 9  N   c||vr|||<yyr;rrps r! setdefaultzDictAttribute.setdefaults d?DI r c` t|j|S#t$r t|wxYwr;)rhrdrXrWris r! __getitem__zDictAttribute.__getitem__s1 488S) ) 3-  s-c2t|j||yr;rlr]s r!r2zDictAttribute.__setitem__s#u%r c.t|j|Sr;)rRrdris r! __contains__zDictAttribute.__contains__rjr c>tt|jSr;)r=dirrdr?s r! _iterate_keyszDictAttribute._iterate_keyssCM""r c"|jSr;r~r?s r!__iter__zDictAttribute.__iter__s!!##r c#jK|jD]}|t|j|fywr;r~rhrdris r!_iterate_itemszDictAttribute._iterate_itemss/%%'Cwtxx-- -(s13c#fK|jD]}t|j|ywr;rris r!_iterate_valueszDictAttribute._iterate_valuess*%%'C$((C( ((s/1r;)rrrrQrdrfrZr_rrrvrxr2r{r~iterkeysrr iteritemsr itervaluesr3r>valuesrr r!r'r'}sn C-&-  &&#H$.I)!J E D Fr r'ceZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ d Zd Zd Zd Zdd ZdZdZdZdZeZddZdZdZedZdZeZdZdZ e Z!dZ"e"Z#dZ$e$Z%dZ&e Z'e"Z(e$Z)y)r%z!Key lookup on a sequence of maps.Nrct|xsig}|jj|jd||d|ddgy)Nkey_trr)rmapschangesdefaults _observers)list__dict__updaterr)r@rkwargss r!rfzChainMap.__init__sKDLRD! **W%G!"X  r ct|}|jjd||jjd|yrI)r+rinsertr)r@ds r! add_defaultszChainMap.add_defaultss4 !  Q" Ar cz |jdj|g|S#t$rtd|wxYw)Nrz$Key not found in the first mapping: )rrErWrps r!rEz ChainMap.popsR @#499Q<##C2'2 2 @6sg>@ @ @s":ct|r;roris r! __missing__zChainMap.__missing__s smr c@|j|j|S|Sr;)rris r!_keyz ChainMap._keys"&**"8tzz#AcAr c|j|}|jD] } ||cS|j|S#t$rY(wxYwr;)rrrWr)r@rFrmappings r!rxzChainMap.__getitem__sSyy~yyG t}$! $$  s; AAc@||j|j|<yr;rrr]s r!r2zChainMap.__setitem__', TYYs^$r ct |j|j|=y#t$rtd|wxYw)Nz Key not found in first mapping: )rrrWris r! __delitem__zChainMap.__delitem__s@ G TYYs^, G=cWEF F Gs7c8|jjyr;rclearr?s r!rzChainMap.clear s r cN ||j|S#t$r|cYSwxYwr;)rrWrps r!rrz ChainMap.get s.  #' ' N s  $$cVttj|jSr;)lensetunionrr?s r!__len__zChainMap.__len__s;35;; *++r c"|jSr;rr?s r!rzChainMap.__iter__s!!##r cb|jtfd|jDS)Nc3&K|]}|v ywr;r).0r0rFs r! z(ChainMap.__contains__..s/3!8/)ranyrris `r!r{zChainMap.__contains__s%iin/TYY///r c,t|jSr;)rrr?s r!__bool__zChainMap.__bool__ s499~r c:|j|}||vr|||<yyr;)rrps r!rvzChainMap.setdefault%s$iin d?DI r cp|jj|i|}|jD] }||i| |Sr;)rrr)r@argsrresultcallbacks r!rzChainMap.update+s=$$$d5f5H d %f %( r c tdj|djtt|jS)Nz{0.__class__.__name__}({1})z, )formatjoinmapreprrr?s r!__repr__zChainMap.__repr__2s.,33 $))Cdii013 3r c:|tj|g|S)z?Create a ChainMap with a single dict created from the iterable.)dictfromkeys)clsiterablers r!rzChainMap.fromkeys7s4==1D122r cx|j|jdjg|jddSrI) __class__rcopyr?s r!rz ChainMap.copy=s3t~~diil//1BDIIabMBBr cLtfdt|jDS)Nc3.K|] }|ywr;r)rrops r!rz!ChainMap._iter..Hs:r!u:)r reversedr)r@rs `r!_iterzChainMap._iterBs :htyy&9:;;r c8t|jdS)Nc"|jSr;)r>)rs r!z(ChainMap._iterate_keys..Ls r )rrr?s r!r~zChainMap._iterate_keysJsDJJ1233r cfdDS)Nc3,K|] }||f ywr;rrrFr@s r!rz*ChainMap._iterate_items..Qs1Sd3i 1srr?s`r!rzChainMap._iterate_itemsOs1D11r cfdDS)Nc3(K|] }| ywr;rrs r!rz+ChainMap._iterate_values..Vs*cS *srr?s`r!rzChainMap._iterate_valuesTs*T**r c:|jj|yr;)rappend)r@rs r!bind_tozChainMap.bind_toYs x(r r;)*rrrrQrrrrrrfrrErrrxr2rrrrrrr{r __nonzero__rvrr classmethodrr__copy__rr~rrrrrrr>r3rrr r!r%r%s+ EGH DJ   @B%-G,$0 K 3 33 CH<4H2I+!J) D E Fr r%cZeZdZdZd fd ZdZfdZdZdZd dZ dZ d Z d Z xZ S) r&aA view over an applications configuration dictionaries. Custom (but older) version of :class:`collections.ChainMap`. If the key does not exist in ``changes``, the ``defaults`` dictionaries are consulted. Arguments: changes (Mapping): Map of configuration changes. defaults (List[Mapping]): List of dictionaries containing the default configuration. c|gn|}t||g||jj|r|j ddzn||y)N_)prefix_keys)superrfrrrstrip)r@rrr>rrs r!rfzConfigurationView.__init__osP!)2x ,8, /56==%+6  r cp|j}|r&|j|s||zn|}t|||fS|fSr;)r startswithr)r@rFrpkeys r!_to_keyszConfigurationView._to_keysxs= '*~~f'=6C<3DdF+S0 0t r cb|j}t|}||jrt fd|jDndzD] } ||cS |j S#t $rY,wxYw#t $r(t|dkDrt dj|wxYw)Nc3.K|] }|ywr;r)rfrFs r!rz0ConfigurationView.__getitem__..s1af1rrrz)Key not found: {0!r} (with prefix: {0!r})) rrrxrtuplerWrrr)r@rFr>getitemr7rs ` r!rxzConfigurationView.__getitem__s}}S!'%59ZZ1djj11RIA qz!I  ##C( (     4y1}F?FFMOO   sA.A=. A:9A:=1B.c@||j|j|<yr;rr]s r!r2zConfigurationView.__setitem__rr c.tdfd|DS)Nc3@K|]}j|ywr;)rrrs r!rz*ConfigurationView.first..s:cDHHSM:s)r)r@r>s` r!rzConfigurationView.firstsT:T:;;r c0 ||S#t$r|cYSwxYwr;rorps r!rrzConfigurationView.getrsrtc8|jjy)z&Remove all changes, but keep defaults.Nrr?s r!rzConfigurationView.clears r cb|j|tfd|jDS)Nc3HK|]tfdDyw)c3&K|]}|v ywr;r)rr7r0s r!rz;ConfigurationView.__contains__...s,!qAv,rN)r)rr0r>s @r!rz1ConfigurationView.__contains__..s@3,t,,@s")rrr)r@rFr>s @r!r{zConfigurationView.__contains__s&}}S!@dii@@@r c|jd}|jd}|jj|||jd|jd|g|zy)Nrrrr)rrrrr)rr)r@otherrrs r! swap_withzConfigurationView.swap_withs]..+>>*- ..)>>(+X%  r )NNNr;)rrrrQrfrrxr2rrrrr{r __classcell__rs@r!r&r&as6  &-< A  r r&ceZdZdZdZddZdZdZdZddZ d Z d Z e Z dd Z dd ed efdZdZdZdZdZdZdZdZdZeZedZy)r)a/Kind-of Set (or priority queue) with limitations. Good for when you need to test for membership (`a in set`), but the set should not grow unbounded. ``maxlen`` is enforced at all times, so if the limit is reached we'll also remove non-expired items. You can also configure ``minlen``: this is the minimal residual size of the set. All arguments are optional, and no limits are enabled by default. Arguments: maxlen (int): Optional max number of items. Adding more items than ``maxlen`` will result in immediate removal of items sorted by oldest insertion time. expires (float): TTL for all items. Expired items are purged as keys are inserted. minlen (int): Minimal residual size of this set. .. versionadded:: 4.0 Value must be less than ``maxlen`` if both are configured. Older expired items will be deleted, only after the set exceeds ``minlen`` number of items. data (Sequence): Initial data to initialize set with. Can be an iterable of ``(key, value)`` pairs, a dict (``{key: insertion_time}``), or another instance of :class:`LimitedSet`. Example: >>> s = LimitedSet(maxlen=50000, expires=3600, minlen=4000) >>> for i in range(60000): ... s.add(i) ... s.add(str(i)) ... >>> 57000 in s # last 50k inserted values are kept True >>> '10' in s # '10' did expire and was purged from set. False >>> len(s) # maxlen is reached 50000 >>> s.purge(now=time.monotonic() + 7200) # clock + 2 hours >>> len(s) # now only minlen items are cached 4000 >>>> 57000 in s # even this item is gone now False Nc(|dn||_|dn||_|dn||_i|_g|_|r|j ||j|jcxk\rdk\st dt d|jdkr t dy)Nrz:minlen must be a positive number, less or equal to maxlen.zexpires cannot be negative!)maxlenminlenexpires_data_heapr ValueError)r@rrdatars r!rfzLimitedSet.__init__s!>av !>av #Oq    KK {{dkk.Q.LN N/LN N <>,M(EFFh'"/ r c\|jj|d|jyr;)rrEr r@rs r!rzLimitedSet.discard:s" tT"   "r cZ|xstj}t|tr|n|}|jrUt |j |jkDr3|jt |j |jkDr3|jrt |j |jcxkDrdk\rdny|jd\}}||jz|kDry|jt |j |jcxkDrdk\r^yyyy)zCheck oldest items and remove them if needed. Arguments: now (float): Time of purging -- by default right now. This can be useful for unit testing. rN) rrr.rrrrrErrr)r@r inserted_timers r!rzLimitedSet.purgeAs%T^^%!#x0cec ;;djj/DKK/ djj/DKK/ <<djj/DKK414#'::a= q 4<</#5 djj/DKK414 r rqr[c|jr6t|j\}} |jj||S|S#t$rYnwxYw|jrT)z?Remove and return the oldest item, or :const:`None` when empty.)rr rrErW)r@rqrrs r!rEzLimitedSet.popVsZjjdjj)GAt  t$     jjsA AAcj|jjDcic]\}}|| c}}Scc}}w)a6Whole set as serializable dictionary. Example: >>> s = LimitedSet(maxlen=200) >>> r = LimitedSet(maxlen=200) >>> for i in range(500): ... s.add(i) ... >>> r.update(s.as_dict()) >>> r == s True )rr)r@rrFs r!as_dictzLimitedSet.as_dictbs-48::3D3D3FG-(CX GGGs /c4|j|jk(Sr;r)r@rs r!__eq__zLimitedSet.__eq__rszzU[[((r cjtj|t|jt |S)N)namesize)REPR_LIMITED_SETrrYrrr?s r!rzLimitedSet.__repr__vs/&& tDz**T'  r cVdt|jjDS)Nc3&K|] \}}| ywr;r)rris r!rz&LimitedSet.__iter__..~s:da:s)sortedrrr?s r!rzLimitedSet.__iter__|s:fTZZ%6%6%89::r c,t|jSr;)rrr?s r!rzLimitedSet.__len__s4::r c||jvSr;r!ris r!r{zLimitedSet.__contains__sdjj  r c~|j|j|j|j|jffSr;)rrrrrr?s r! __reduce__zLimitedSet.__reduce__s6~~ KKt||~t{{ DD Dr c,t|jSr;)boolrr?s r!rzLimitedSet.__bool__sDJJr cxt|jdztt|jdz dz S)z5Compute how much is heap bigger than data [percents].dr)rrmaxrr?s r!r zLimitedSet._heap_overloads04::$s3tzz?A'>>DDr )rrNrr;)rrrrQr rfrr rrrr pop_valuerrrErr"rrrr{r.rrpropertyr rr r!r)r)s3j!#<$ !  4# I* 3 # H ) ;!D  K EEr r)c:eZdZdZeZd dZdefdeddfdZd dZ y) r(z2Mixin for classes supporting the ``evict`` method.r[Nc0|jty)z&Force evict until maxsize is enforced.)rangeN)_evictrr?s r!evictzEvictable.evicts %  r r2limitcv ||Dcgc]}|jc}ycc}w#t$rYywxYwr;)_evict1 IndexError)r@r;r8rs r!r9zEvictable._evicts4 %*5\ 2T\\^ 2 2   s ,',, 88c|j|jkr t |jy#|j$r twxYwr;) _evictcountmaxsizer> _pop_to_evictrr?s r!r=zEvictable._evict1sH   t|| +,      zz ,  s 6A)r[N) rrrrQrr:r8intr9r=rr r!r(r(s.< E!#&UCt r r(creZdZdZeZdefdZdZdZdZ dZ dZ d Z d Z d efd Zd ZdZedZy)r*zA buffer of pending messages.Nc ||_||xsg|_|jj|_|jj|_|jj |_|jj|_ yr;) rArr_appendpopleft_popr_lenextend_extend)r@rArrs r!rfzMessagebuffer.__init__s] (.b) yy'' II%% II%% yy'' r cf|j||jxr|jyyr;)rFrAr9rs r!putzMessagebuffer.puts# T &&r cf|j||jxr|jyyr;)rKrAr9)r@its r!rJzMessagebuffer.extends# R &&r cp |jS#t$r|r|dcYS|jwxYw)Nr)rHr>rr@rqs r!takezMessagebuffer.takes; 99;  qz!**,  s 55c"|jSr;)rRr?s r!rBzMessagebuffer._pop_to_evictyy{r cfdt|jdt|d|jdSN)rYrrrAr?s r!rzMessagebuffer.__repr__s04:&&'r#d)Adll^1EEr c#RK |j#t$rYywxYwwr;)rHr>r?s r!rzMessagebuffer.__iter__s2 iik!  s'' $'$'c"|jSr;)rIr?s r!rzMessagebuffer.__len__rTr r[c||jvSr;rrs r!r{zMessagebuffer.__contains__styy  r c,t|jSr;)rrr?s r! __reversed__zMessagebuffer.__reversed__s ""r c |j|Sr;r])r@indexs r!rxzMessagebuffer.__getitem__syyr ct|Sr;rr?s r!r@zMessagebuffer._evictcounts4yr )rrrrQrrrfrMrJrRrBrrrr0r{r_rxr5r@rr r!r*r*sb' E)-U(' ' F!D!# r r*cxeZdZdZeZeZdZdZdZ dfd Z dZ dZ dZ dZd Zd Zd Zd Zed ZxZS)r$zMap of buffers.Nrct|||_d|_|r|j |t d|j D|_y)Nc32K|]}t|ywr;rc)rbufs r!rz%BufferMap.__init__..s:cS:s)rrfrA bufmaxsizersumr3total)r@rArrirs r!rfzBufferMap.__init__sC    KK !:TZZ\:: r c|j|j||xjdz c_|j||jxr|j yy)Nr)_get_or_create_bufferrMrkrBrAr9)r@rFrs r!rMz BufferMap.putsK ""3'++D1 a   &&r c|j|j||xjt|z c_|jxr|j yyr;)rmrJrkrrAr9)r@rFrOs r!rJzBufferMap.extendsB ""3'..r2 c"g  &&r c d\}} ||} |j}|xjdzc_|j||r|r|dS|j|S#|j$rd}Y.wxYw#t$rd}Y?wxYw)N)NFrTr)rRrkrBrrW)r@rFrqrthrowrhs r!rRzBufferMap.takes! e &s)C &xxz a   % qz!**,  ::    E s"A5%AA21A25 BBcZ ||S#t$r|jx}||<|cYSwxYwr;)rW _new_buffer)r@rFrhs r!rmzBufferMap._get_or_create_buffer3s< 9  "..0 0C$s)J s  **c:|j|jS)N)rA)Bufferrir?s r!rrzBufferMap._new_buffer;s{{4??{33r cB||jj|Sr;)rArRrQs r!_LRUpopzBufferMap._LRUpop?s (tDLLN#(('22r cRtdD]m}|j}||} |j|xjdzc_t |s|j |y|j |yy#t|jf$r|j |YwxYw)Nr2r) r8rArRrkrrErBr>r)r@rrFrhs r!rBzBufferMap._pop_to_evictCssA,,.Cs)C   a 3xHHSM$$S)#  +   sA==&B&%B&chdt|jd|jd|jdSrV)rYrrkrAr?s r!rzBufferMap.__repr__Xs04:&&'r$**Qt||nAFFr c|jSr;)rkr?s r!r@zBufferMap._evictcount\szzr )Nrf)rrrrQr*rtrrArkrirfrMrJrRrmrrrvrBrr5r@rrs@r!r$r$sa F EG EJ;'' ,43*Gr r$)5rQr collectionsrrSrcollections.abcrrrrr heapqr r r itertoolsr rqueuertypingrrrr functionalrrtextr__pypy__rrT ImportErrordjango.utils.functionalrr__all__r&r+r,r"rr#r'registerr%r&r)r(r*r$rr r!rsR> 3SS,,",,#:@   A (3,(3V(/D,/GGT &T~TnU "4U p]E]E@ J0CICL- b YbY   Ls$DDDDD21D2