`fXcdZddlZddlmZddlmZddlmZmZm Z m Z m Z ddl m Z mZmZddlmZmZddlmZdd lmZmZmZmZd d lmZmZd d lmZ dd lm Z!n #e"$rdZ!YnwxYw ddl#m$Z$m%Z%n#e"$rGddZ$e$Z%YnwxYwdZ&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(ee2Z4dS))z8Custom maps, sets, sequences, and other data structures.N) OrderedDict)deque)CallableMappingMutableMapping MutableSetSequence)heapifyheappopheappush)chaincount)Empty)AnyDictIterableList)firstuniq) match_case) reversed_dict) LazyObject LazySettingsceZdZdS)rN)__name__ __module__ __qualname__J/var/www/html/env/lib/python3.11/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|tst |n|S)z?Wrap object into supporting the mapping interface if necessary.) isinstancerr_wrappedrr')ms r!r+r+'sD!j,/00 J#-a#9#9 @=   q@r cV|jfd|D|S)zpIn place left precedent dictionary merge. Keeps values from `L`, if the value in `R` is :const:`None`. c2g|]\}}|||SNr).0kvsetitems r! zlpmerge..6s(:::tq!AMWWQ]]MMMr ) __setitem__items)LRr7s @r!r,r,/s3 mG::::qwwyy:::: Hr cLeZdZdZdZeedserddZdSddZdSdS) rz#Dict where insertion order matters.c^tt|Sr3)nextiterkeysselfs r!_LRUkeyzOrderedDict._LRUkey=s"D%%&&&r move_to_endTcX|std||||<dS)Nzno last=True on PyPy)NotImplementedErrorpop)rCkeylasts r!rEzOrderedDict.move_to_endFs3F..DEEE HHSMMS r c|j|}|d}|d}||d<||d<|j}|r|d}||d<||d<|x|d<|d<dS|d}||d<||d<|x|d<|d<dSNrr)_OrderedDict__map_OrderedDict__root)rCrIrJlink link_prev link_nextroot first_nodes r!rEzOrderedDict.move_to_endQs-c2 G  G ( ! ( ! . 37D"DG"DG(,,DGd1ggg!%aJ"DG(DG.22DGjmmmr N)T) rrr__doc__rDhasattr _OrderedDict_dict_is_orderedrErr r!rr:s--''' 7< / /3  3 * * * * * * 3 3 3 3 3 333r rc(eZdZdZdZdeddfdZdS)r"z[Mixin for Mapping interface that adds attribute access. I.e., `d.key -> d[key]`). c| ||S#t$r'tt|jd|wxYw)z`d.key -> d[key]`.z object has no attribute )KeyErrorAttributeErrortyper)rCr5s r! __getattr__zAttributeDictMixin.__getattr__ks_ J7N J J J ::&HH1HHJJ J Js 1;rIreturnNc|||<dS)z"`d[key] = value -> d.key = value`.NrrCrIvalues r! __setattr__zAttributeDictMixin.__setattr__tsS r )rrrrTr]strrbrr r!r"r"esR JJJsdr r"ceZdZdZdS)r#z$Dict subclass with attribute access.N)rrrrTrr r!r#r#ys....r r#czeZdZdZdZdZdZdZddZddZ dZ d Z d Z d Z e Zd Zd ZeZdZeZeZe ZeZdS)r'z[Dict interface to attributes. `obj[k] -> obj.k` `obj[k] = val -> obj.k = val` Nc>t|d|dS)Nobj)objectrb)rCrgs r!__init__zDictAttribute.__init__s 4,,,,,r c,t|j|Sr3)getattrrgrCrIs r!r]zDictAttribute.__getattr__tx%%%r c.t|j||Sr3setattrrgr`s r!rbzDictAttribute.__setattr__stxe,,,r c8 ||S#t$r|cYSwxYwr3rZrCrIdefaults r!getzDictAttribute.get5 9    NNN   c||vr|||<dSdSr3rrss r! setdefaultzDictAttribute.setdefaults d??DIII ?r ch t|j|S#t$rt|wxYwr3)rkrgr[rZrls r! __getitem__zDictAttribute.__getitem__s@ 48S)) )   3--  s1c2t|j||dSr3ror`s r!r9zDictAttribute.__setitem__s#u%%%%%r c,t|j|Sr3)rUrgrls r! __contains__zDictAttribute.__contains__rmr cDtt|jSr3)r@dirrgrBs r! _iterate_keyszDictAttribute._iterate_keyssCMM"""r c*|Sr3rrBs r!__iter__zDictAttribute.__iter__s!!###r c#jK|D]}|t|j|fVdSr3rrkrgrls r!_iterate_itemszDictAttribute._iterate_itemssK%%'' . .Cwtx--- - - - - . .r c#fK|D]}t|j|VdSr3rrls r!_iterate_valueszDictAttribute._iterate_valuessF%%'' ) )C$(C(( ( ( ( ( ) )r r3)rrrrTrgrir]rbruryr{r9r~riterkeysrr iteritemsr itervaluesr:rAvaluesrr r!r'r'}s C---&&&---       &&&&&&###H$$$...I)))!J E D FFFr 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)dS)r%z!Key lookup on a sequence of maps.Nrct|pig}|j|d||d|ddgdS)Nkey_trr)rmapschangesdefaults _observers)list__dict__updateru)rCrkwargss r!rizChainMap.__init__seDLRD!! **W%%G!""X      r ct|}|jd||jd|dSrL)r+rinsertr)rCds r! add_defaultszChainMap.add_defaultssE !   Q""" Ar cv |jdj|g|RS#t$rtd|wxYw)Nrz$Key not found in the first mapping: )rrHrZrss r!rHz ChainMap.popsh @#49Q<#C2'222 2 @ @ @>s>>@@ @ @s8c t|r3rrrls r! __missing__zChainMap.__missing__ssmmr c>|j||n|Sr3)rrls r!_keyz ChainMap._keys"&*"8tzz#cAr c||}|jD]} ||cS#t$rYwxYw||Sr3)rrrZr)rCrIrmappings r!r{zChainMap.__getitem__skyy~~y  G t}$$$    $$$s * 77c@||j||<dSr3rrr`s r!r9zChainMap.__setitem__', TYYs^^$$$r c~ |j||=dS#t$rtd|wxYw)Nz Key not found in first mapping: )rrrZrls r! __delitem__zChainMap.__delitem__sX G TYYs^^,,, G G GEcEEFF F Gs<c8|jdSr3rclearrBs r!rzChainMap.clear s r c^ |||S#t$r|cYSwxYwr3)rrZrss r!ruz ChainMap.get s@  #' '   NNN s  ,,cRttj|jSr3)lensetunionrrBs r!__len__zChainMap.__len__s;355; *+++r c*|Sr3rrBs r!rzChainMap.__iter__s!!###r cn|tfd|jDS)Nc3 K|]}|vV dSr3r)r4r0rIs r! z(ChainMap.__contains__..s'//3!8//////r )ranyrrls `r!r~zChainMap.__contains__s7iinn////TY//////r c*t|jSr3)rrrBs r!__bool__zChainMap.__bool__ s49~~r cF||}||vr|||<dSdSr3)rrss r!ryzChainMap.setdefault%s.iinn d??DIII ?r cN|jj|i|}|jD] }||i| |Sr3)rrr)rCargsrresultcallbacks r!rzChainMap.update+sI$$d5f55 & &H Hd %f % % % % r c d|dtt|jS)Nz{0.__class__.__name__}({1})z, )formatjoinmapreprrrBs r!__repr__zChainMap.__repr__2s7,33 $))Cdi001133 3r c8|tj|g|RS)z?Create a ChainMap with a single dict created from the iterable.)dictfromkeys)clsiterablers r!rzChainMap.fromkeys7s&s4=1D111222r cr|j|jdg|jddRSrL) __class__rcopyrBs r!rz ChainMap.copy=s8t~dil//11BDIabbMBBBBr cRtfdt|jDS)Nc3.K|]}|VdSr3r)r4rops r!rz!ChainMap._iter..Hs+::rr!uu::::::r )r reversedr)rCrs `r!_iterzChainMap._iterBs/ ::::hty&9&9:::;;r cHt|dS)Nc*|Sr3)rA)rs r!z(ChainMap._iterate_keys..Lsr )rrrBs r!rzChainMap._iterate_keysJs DJJ1122333r c fdDS)Nc3,K|]}||fVdSr3rr4rIrCs r!rz*ChainMap._iterate_items..Qs,11Sd3i 111111r rrBs`r!rzChainMap._iterate_itemsOs1111D1111r c fdDS)Nc3(K|] }|V dSr3rrs r!rz+ChainMap._iterate_values..Vs'**cS ******r rrBs`r!rzChainMap._iterate_valuesTs****T****r c:|j|dSr3)rappend)rCrs r!bind_tozChainMap.bind_toYs x(((((r r3)*rrrrTrrrrrrirrHrrr{r9rrrurrr~r __nonzero__ryrr classmethodrr__copy__rrrrrrrrrAr:rrr r!r%r%s++ EGH DJ     @@@BBB%%%---GGG,,,$$$000 K    333 33[3 CCCH<<<444H222I+++!J))) D E FFFr r%cZeZdZdZd fd ZdZfdZdZdZd dZ d Z 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. Nc|gn|}tj|g|R|j|r|ddzn||dS)N_)prefix_keys)superrirrrstrip)rCrrrArrs r!rizConfigurationView.__init__osz!)22x,8,,,, /5A6==%%++6      r cv|j}|r.||s||zn|}t|||fS|fSr3)r startswithr)rCrIrpkeys r!_to_keyszConfigurationView._to_keysxsK  1'*~~f'='=F6C<<3DdF++S0 0t r c|}tj}||jr t fd|jDndzD]} ||cS#t $rYwxYw |S#t $r,t|dkrt dj|wxYw)Nc3.K|]}|VdSr3r)r4frIs r!rz0ConfigurationView.__getitem__..s+11aaff111111r rrz)Key not found: {0!r} (with prefix: {0!r})) rrr{rtuplerZrrr)rCrIrAgetitemr5rs ` r!r{zConfigurationView.__getitem__s}}S!!''%59ZG1111dj111111RI  A wqzz!!!     ##C(( (   4yy1}}F?FMOOO   s A'' A43A48B 6Cc@||j||<dSr3rr`s r!r9zConfigurationView.__setitem__rr c<tdfd|DS)Nc3BK|]}|VdSr3)rurs r!rz*ConfigurationView.first..s-::cDHHSMM::::::r )r)rCrAs` r!rzConfigurationView.firsts(T::::T:::;;;r c8 ||S#t$r|cYSwxYwr3rrrss r!ruzConfigurationView.getrvrwc8|jdS)z&Remove all changes, but keep defaults.NrrBs r!rzConfigurationView.clears r cn||tfd|jDS)Nc3PK|]tfdDV dS)c3 K|]}|vV dSr3r)r4r5r0s r!rz;ConfigurationView.__contains__...s',,!qAv,,,,,,r N)r)r4r0rAs @r!rz1ConfigurationView.__contains__..sA@@3,,,,t,,,,,@@@@@@r )rrr)rCrIrAs @r!r~zConfigurationView.__contains__s9}}S!!@@@@di@@@@@@r c|jd}|jd}|j|||jd|jd|g|zdS)Nrrrr)rrrrr)rr)rCotherrrs r! swap_withzConfigurationView.swap_withsg.+>*- .)>(+X%      r )NNNr3)rrrrTrirr{r9rrurr~r __classcell__rs@r!r&r&as        &---<<< AAA        r r&ceZdZdZdZddZdZdZdZdd Z d Z d Z e Z dd Z dd edefdZdZdZdZdZdZdZdZdZeZedZdS)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 rNc|dn||_|dn||_|dn||_i|_g|_|r|||j|jcxkrdksnt d|jdkrt ddS)Nrz:minlen must be a positive number, less or equal to maxlen.zexpires cannot be negative!)maxlenminlenexpires_data_heapr ValueError)rCrrdatars r!rizLimitedSet.__init__s!>aav !>aav #Oqq     KK   {dk....Q....LNN N .s@@@5@@@r N)rrrr rBs r! _refresh_heapzLimitedSet._refresh_heapsFA@DJ,=,=,?,?@@@ 111  r cR|j|jkr|dSdSr3)_heap_overloadmax_heap_percent_overloadr rBs r!_maybe_refresh_heapzLimitedSet._maybe_refresh_heap s4  $"@ @ @     A @r cP|jg|jdd<dS)z)Clear all data, start from scratch again.N)rrrrBs r!rzLimitedSet.clears+  111 r c*|ptj}||jvr||||f}||j|<t |j||jr3t|j|jkr|dSdSdS)z=Add a new item, or reset the expiry time of an existing item.N) time monotonicrdiscardr rrrpurge)rCitemnowrs r!addzLimitedSet.adds%T^%% 4:   LL   d   4U### ; 3tz??dk99 JJLLLLL  99r cB|sdSt|trI|j|j||dSt|t r|D]v\}}t|ttfr|d}t|ts"tdt|d|| ||wdS|D]}| |dS)z8Update this set from other LimitedSet, dict or iterable.Nrz$Expecting float timestamp, got type z with value: )r.r)rrr rrr:rrfloatrr\r)rCrrIinsertedrgs r!rzLimitedSet.update sK  F eZ ( (  J  ek * * *    JJLLLLL t $ $ !& ( ( Xh 66+'{H!(E22F$E>>EE:BEEFFFh'''' ( (     r cd|j|d|dSr3)rrHr rCrs r!rzLimitedSet.discard:s2 tT"""   """""r c8|ptj}t|tr |n|}|jrNt |j|jkr1|t |j|jk1|jrt |j|j cxkrdkrcndS|j d\}}||jz|krdS|t |j|j cxkrdkXdSdSdSdS)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.rrrrrHrrr)rCr inserted_timers r!rzLimitedSet.purgeAs*%T^%%!#x009cceeec ; dj//DK// dj//DK// < dj//DK44441444444#':a= q 4</#55E dj//DK444414444444  44r rtr^c|jrKt|j\}} |j||S#t$rYnwxYw|jK|S)z?Remove and return the oldest item, or :const:`None` when empty.)rr rrHrZ)rCrtrrs r!rHzLimitedSet.popVstj dj))GAt  t$$$      j s< A A cHd|jDS)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 ci|]\}}|| Srr)r4rrIs r! z&LimitedSet.as_dict..psGGG-(CXGGGr )rrrBs r!as_dictzLimitedSet.as_dictbs'HG4:3D3D3F3FGGGGr c"|j|jkSr3r)rCrs r!__eq__zLimitedSet.__eq__rszU[((r czt|t|jt |S)N)namesize)REPR_LIMITED_SETrr\rrrBs r!rzLimitedSet.__repr__vs5&& tDzz*T'   r cbdt|jDS)Nc3 K|] \}}|V dSr3r)r4ris r!rz&LimitedSet.__iter__..~s&::da::::::r )sortedrrrBs r!rzLimitedSet.__iter__|s,::fTZ%6%6%8%899::::r c*t|jSr3)rrrBs r!rzLimitedSet.__len__s4:r c||jvSr3r$rls r!r~zLimitedSet.__contains__sdj  r c^|j|j|j||jffSr3)rrrr"rrBs r! __reduce__zLimitedSet.__reduce__s0~ Kt||~~t{ DD Dr c*t|jSr3)boolrrBs r!rzLimitedSet.__bool__sDJr c|t|jdztt|jdz dz S)z5Compute how much is heap bigger than data [percents].dr)rrmaxrrBs r!r zLimitedSet._heap_overloads34:$s3tz??A'>'>>DDr )rrNrr3)rrrrTr rir r rrrr pop_valuerrrHr"r%rrrr~r1rrpropertyr rr r!r)r)s33j!#<<<<$ !!!     4### I*  3 #    HHH )))   ;;;!!!DDD    K EEXEEEr r)c<eZdZdZeZd dZdefdeddfdZd dZ dS) r(z2Mixin for classes supporting the ``evict`` method.r^Nc<|tdS)z&Force evict until maxsize is enforced.)rangeN)_evictrrBs r!evictzEvictable.evicts %      r r5limitcZ fd||DdS#t$rYdSwxYw)Nc8g|]}Sr)_evict1)r4rrCs r!r8z$Evictable._evict..s! 2 2 2T\\^^ 2 2 2r ) IndexError)rCr>r;s` r!r<zEvictable._evictsR  2 2 2 2UU5\\ 2 2 2 2 2 2    DD s  **c|j|jkrt |dS#|j$rtwxYwr3) _evictcountmaxsizerB _pop_to_evictrrBs r!rAzEvictable._evict1s`  t| + +,,      z   ,,  s 6A)r^N) rrrrTrr=r;intr<rArr r!r(r(su<< E!!!!#&UCt r r(czeZdZdZeZdefdZdZdZdZ dZ dZ d Z d Z d efd Zd ZdZedZdS)r*zA buffer of pending messages.Nc||_||pg|_|jj|_|jj|_|jj|_|jj|_ dSr3) rErr_appendpopleft_popr_lenextend_extend)rCrErrs r!rizMessagebuffer.__init__sR E(.b)) y' I% I% y' r cl|||jo|dSdSr3)rJrEr<rs r!putzMessagebuffer.puts5 T &&&&r cl|||jo|dSdSr3)rOrEr<)rCits r!rNzMessagebuffer.extends5 R &&&&r c |S#t$r!|r |dcYS|wxYw)Nr)rLrBrrCrts r!takezMessagebuffer.takesV 99;;     "qz!!!**,,  sAAc*|Sr3)rVrBs r!rFzMessagebuffer._pop_to_evictyy{{r cbdt|jdt|d|jdSN)r\rrrErBs r!rzMessagebuffer.__repr__s4E4::&EE#d))EEdlEEEEr c#\K |Vn#t$rYdSwxYw*r3)rLrBrBs r!rzMessagebuffer.__iter__sN  iikk!!!!     s  **c*|Sr3)rMrBs r!rzMessagebuffer.__len__rXr r^c||jvSr3rrs r!r~zMessagebuffer.__contains__sty  r c*t|jSr3)rrrBs r! __reversed__zMessagebuffer.__reversed__s """r c|j|Sr3ra)rCindexs r!r{zMessagebuffer.__getitem__syr c t|Sr3rrBs r!rDzMessagebuffer._evictcounts4yyr )rrrrTrrrirQrNrVrFrrrr3r~rcr{r8rDrr r!r*r*s'' E)-U((((''' ''' FFF!D!!!!###   Xr r*c~eZdZdZeZeZdZdZdZ dfd Z dZ dZ dZ d Zd Zd Zd Zd ZedZxZS)r$zMap of buffers.Nrct||_d|_|r||t d|D|_dS)Nric34K|]}t|VdSr3rg)r4bufs r!rz%BufferMap.__init__..s(::cS::::::r )rrirE bufmaxsizersumr:total)rCrErrmrs r!rizBufferMap.__init__sk    " KK ! ! !::TZZ\\::::: r c||||xjdz c_|||jo|dSdS)Nr)_get_or_create_bufferrQrorErEr<)rCrIrs r!rQz BufferMap.putsh ""3''++D111 a   &&&&r c||||xjt|z c_|jo|dSdSr3)rqrNrorrEr<)rCrIrSs r!rNzBufferMap.extends[ ""3''..r222 c"gg  &&&&r c d\}} ||} |}|xjdzc_||n$#|j$rd}YnwxYw#t$rd}YnwxYw|r|r|dS||S)N)NFrTr)rVrorErrZ)rCrIrtrthrowrls r!rVzBufferMap.takes! e &s)C &xxzz a   %%%%:        EEE    "qz!**,,  s"A$A AA A+*A+cj ||S#t$r|x}||<|cYSwxYwr3)rZ _new_buffer)rCrIrls r!rqzBufferMap._get_or_create_buffer3sO 9    "..00 0C$s)JJJ s  %22c8||jS)N)rE)BufferrmrBs r!rvzBufferMap._new_buffer;s{{4?{333r cF||j|Sr3)rDrVrUs r!_LRUpopzBufferMap._LRUpop?s(tDLLNN#('22r c|tdD]}|}||} ||xjdzc_t |s||n||dS#t|jf$r||YwxYwdS)Nr5r) r;rDrVrorrHrErBr)rCrrIrls r!rFzBufferMap._pop_to_evictCss  A,,..Cs)C   a 3xx*HHSMMMM$$S))) +        sB&B98B9cRdt|jd|jd|jdSrZ)r\rrorErBs r!rzBufferMap.__repr__Xs0F4::&FF$*FFt|FFFFr c|jSr3)rorBs r!rDzBufferMap._evictcount\s zr )Nri)rrrrTr*rxrrErormrirQrNrVrqrvrzrFrr8rDrrs@r!r$r$s F EG EJ;;;;;;'''''' ,444333*GGGXr r$)5rTr collectionsrrVrcollections.abcrrrrr heapqr r r itertoolsr rqueuertypingrrrr functionalrrtextr__pypy__rrW ImportErrordjango.utils.functionalrr__all__r)r+r,r"rr#r'registerr%r&r)r(r*r$rr r!rs>> 333333SSSSSSSSSSSSSS,,,,,,,,,,"""""""",,,,,,,,,,,,########:::::::@@@@@@@@@        LLL   AAA   (3(3(3(3(3,(3(3(3V(/////D,///GGGGGGGGT &&&TTTTT~TTTnU U U U U "4U U U p]E]E]E]E]E]E]E]E@ J0CCCCCICCCL- bbbbb Ybbbbbs$AA%$A%)A22B B