BeN8HdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZ ddlZddlmZddlZddlmZddlmZdZdZiZejZed efiZeee e!e"e#edfZ$d Z%d Z&d Z'd Z(e j)d kre j*Z+ne j,Z+Gd d eZ-dZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7ie!e/ede de"dedde8e3ee#fde9e:e;fe2ej<dej=e4e j>j?dej@ejAfe7ejBdd e6d!e5d"e5d#e5d$e5d%e3d&d'd(d)d*d+d,d-ejCd.ejDd/d0d1i ZEeD]ZFd2eEeF<d3ZGd4ZHd5ZId6ZJd7ZKd8ZLed9ZMd:ZN d?d>ZOdS)@z? Implements memoization for functions with arbitrary arguments N)contextmanager)iscoroutinefunction)states.panel-93KZ39Q-floatingdangeroushomechose-CYCLE)z_cffi_backend.FFIzbuiltins.CompiledFFI INDETERMINATEiwin32c&eZdZdZdZdZdZdS)_Stackci|_dSN)_stackselfs .lib/python3.11/site-packages/panel/io/cache.py__init__z_Stack.__init__<s  c4||jt|<dSr )r idrvals rpushz _Stack.push?s" BsGGrc8|jdSr )r popitemrs rpopz _Stack.popBs rc.t||jvSr )rr rs r __contains__z_Stack.__contains__Es#ww$+%%rN)__name__ __module__ __qualname__rrrrrrr r :sP###&&&&&rr cJt|}|j}|j}|d|S)z&Get module.type_name for a given type..)typerr)objthe_typemodulenames r_get_fqnr(Hs.CyyH  F  Dffdd ##rcf|dzdz}||ddS)NlittleT)signed) bit_lengthto_bytes)i num_bytess r _int_to_bytesr1Os1!#)I ::i$: 7 77rc,t|tSr ) isinstance _NATIVE_TYPESr$s r _is_nativer6Ss c= ) ))rc^t|totd|DS)Nc34K|]}t|VdSr )_is_native_tuple).0vs r z#_is_native_tuple..Ws+)K)K!*:1*=*=)K)K)K)K)K)Kr)r3tupleallr5s rr9r9Vs. c5 ! ! Kc)K)Ks)K)K)K&K&KKrc`tjd}|tdt |jt |tr|n|D]$}|t|%| S)Nmd5__) hashlibnewupdate_generate_hashr#rr3dictitemsdigest)r$hitems r_container_hashrKYs EAHH^5c!355 6 6777 *3 5 5>3'' %%&&&& 88::rcDt|j|j|jgSr )rKstartstepstopxs r _slice_hashrR`s AGQVQV4 5 55rc<tjd}|t|j|t|j|t|j|SNr@)rBrCrDrEargsfunckeywordsrHr$rIs r _partial_hashrYcss EAHH^CH % %&&&HH^CH % %&&&HH^CL ) )*** 88::rcddl}t||j|jfs||}t |t kr|td} d|j | zS#t$r%dtj |tjzcYSwxYw)Nr)n random_states%s)pandasr3Series DataFramelen_PANDAS_ROWS_LARGEsample_PANDAS_SAMPLE_SIZEutilhash_pandas_objectsum TypeErrorpickledumpsHIGHEST_PROTOCOL)r$pds r _pandas_hashrljs cBIr|4 5 5iinn 3xx%%%jj.Qj??Brw11#66::<<<< BBBv|C)@AAAAAABs+.B,C C ctjd}|t|j|jt kr:ddl}|j d}|j |j t}|| |S)Nr@r)size)rBrCrDrEshapern_NP_SIZE_LARGEnumpyrandom RandomStatechoiceflat_NP_SAMPLE_SIZEtobytesrH)r$rInprs r _numpy_hashryys EAHH^CI & &''' x>!! %%a((el38/:::HHS[[]] 88::rc"tjd}|t||t||SrT)rBrCrDrEtellgetvaluerHrXs r_io_hashr}sc EAHH^CHHJJ ' '(((HH^CLLNN + +,,, 88::rc*|Sr )encoder5s rrsszz||rc:tt|Sr )r1hashr5s rrrs}T#YY77rc|durdndS)NT10r r5s rrrssd{{ttrcdS)Nrr r5s rrrstrc|Sr r r5s rrrsSrcDt|Sr )strrr5s rrrsSXX__%6%6rc:tt|Sr )r1rr5s rrrs]2c77%;%;rcXt|j|dS)Nzutf-8)r#rrr5s rrrs($s))"4;c;;BB7KKr numpy.ndarrayzpandas.core.series.Seriespandas.core.frame.DataFramezpandas.core.indexes.base.Indexz&pandas.core.indexes.numeric.Int64Indexz$pandas.core.indexes.range.RangeIndexzbuiltins.mappingproxyc:tt|Sr rKrFr5s rrrtCyy/I/Irzbuiltins.dict_itemsc:tt|Sr rr5s rrrrrzbuiltins.getset_descriptorc4|jSr )rrr5s rrrss/?/F/F/H/Hrz numpy.ufuncc4|jSr rrr5s rrrss|/B/B/D/Drc4|jSr rr5s rrrsS\-@-@-B-Brc|jSr )rr5s rrrsS\rc8t|do |jdkS)Nrwr )hasattrrorPs rrrsga##52 rc*|Sr )rwrPs rrrsrrc>t|}|tvr t|StD]]\}}t|tr ||kr|cS%t j|r||r|cSIt||r|cS^dSr )r( _hash_funcsrGr3rinspect isfunction)r$fqn_typeotype hash_funcs r_find_hash_funcrs}}H;8$$'--//y eS ! !       !   & & uSzz !     ! U # #     rc Ht|}|O ||}n@#t$r3}td|d|dt|jd|d d}~wwxYw|St |drt jd} |}n2#t$r%tdt|jwxYw|D]$}| t|%| Stt|S) NzUser hash function z failed for input z with following error: z("z"). __reduce__r@zCould not hash object of type )r BaseException ValueErrorr#rrrBrCrrDrErHr1r)r$routputerI reduce_datarJs r_generate_hash_innerrsv$$I Ys^^FF   LiLLLL15a1ALLEFLLL    sL!! K   T..**KK T T TRd3ii>PRRSS S T + +D HH^D)) * * * *xxzz C ! !!s  A.AAB/C ctj}||vrtS|| t |}|n#|wxYw|Sr )r_current_stack_CYCLE_PLACEHOLDERrrr)r$ hash_stack hash_values rrErEsn%J j!!OOC)#..   s AA(c|dSt|st|r|St|tr t d|Drdg|RSnqt |dksOt |dks.s*00Dz$000000r__listrr) r6r9r3listr>r(r isbuiltin isroutineiscoder_INDETERMINATEr5s r_keyrs {t C ,S11  C    00C000 0 0 $#s## # $  666 C==O + +  S ! ! ,  S ! ! , >#   , #ww rct||kr|dkr(t|d}n|dkr=t fd|Dddd}nH|dkr0t |d dd}||=t||kd Sd S) zs Deletes items in the cache if the exceed the number of items or their TTL (time-to-live) has expired. fiforlruc36K|]\}\}}}}||z fVdSr r )r:k_ttimes rr<z!_cleanup_cache..s7KK/!\aAq1d1f+KKKKKKrc|dS)Nrr os rrz _cleanup_cache..s qtr)keylfuc|ddS)Nrr rs rrz _cleanup_cache..sad1grN)r`lowerrkeyssortedrG)cachepolicy max_itemsrrs ` r_cleanup_cachers e** ! ! <<>>V # #uzz||$$Q'CC \\^^u $ $KKKKU[[]]KKK+^----/1124CC \\^^u $ $,=,=>>>qA!DC #J e** ! ! ! ! ! !rcvt|D]\}\}}}}||z |kr||=dS)zM Deletes items in the cache if their TTL (time-to-live) has expired. N)rrG)rttlrrrtss r _cleanup_ttlrsO#5;;==11]aQ Gs??c rc#FKtt}t| dVtt|dS#tt|wxYwr )rFrrDclear) hash_funcsbackups r_override_hash_funcsrs +  Fz"""# 6""""" 6""""s A++5B c|t|t|f}t|vr|tvr t|Stjd}t |5|r"|t||r"|t|dddn #1swxYwY|}t|vr |t|<|S)a< Computes a hash given a function and its arguments. Arguments --------- func: callable The function to cache. hash_funcs: dict A dictionary of custom hash functions indexed by type args: tuple Arguments to hash kwargs: dict Keyword arguments to hash r@N) rr _HASH_MAPrBrCrrDrE hexdigest)rVrrUkwargsrhasherrs r compute_hashrs dT&\\ *CS  SI%5%5~ [  F j ) )22  0 MM... / / /  2 MM.00 1 1 1 222222222222222 !!##JS  # # s"A B77B;>B;LRUF./cachec n dvrtddpi fdSd}tj  f d t r"t j fd n!t j fd d fd } | _r.Xs(!!    rc j}o@tdto%tt d|du}|}}|rtdt jrltdi}tfd|ddDddz}t|difi|}t||}t}tj j} jdkrdn| j} |r#| t djjfan | jfar"t t#t$jfz at)jt-t at$jt } | Or5dd lm} | t6jt } ni} | xt$jt <} t=| ||| vr| ||fSt?| || ||fS) Nr_dinfoc3DK|]}td|VdS)rN)getattr)r:drUs rr<z+cache..hash_func..os1YYagd1gq11YYYYYYr dependenciesr rkw__main__Index) rr3objectrr#param Parameterizedr=getrFr_TIME_FNsysmodulesr__file__ func_hashrrcurdocrBsha256rEr_memoize_cache diskcacherospathjoinrr)rUr func_name is_method hash_args hash_kwargsdinforrr&fname func_cacherrrrVrr per_sessionrrr wrapped_funcs` rrzcache..hash_funcdskM  DZQ00 D DaMM9d 3 3| C "&v;  >*T!We.ABB >L(B77EYYYY599^UW;X;XYYYYY\`abacac\ddIuyyr22==f==K!$ I{KK zz T_-"o;;   /T!W 6 FII .I  - "U\**, ,IN>)#<#<==GGII )--i88   ++++++bgll:yAABB;@ @E  +j ? S$ / / /  # #z4/ /  :vy$ ? ? ?:t++rcK |i|\}}}||vr4 5||\}}}}|||dz|f||<dddn #1swxYwYn1 |i|d{V} 5||d|f||<dddn #1swxYwY|SNrrr rUrrrrretrcountrrVrlocks rrzcache..wrapped_funcsp+49d+Ef+E+E (J DZ''FF(2:(>%CUA.12uQw-EJz*FFFFFFFFFFFFFFF!D$1&11111111BB.14D-AJz*BBBBBBBBBBBBBBBJs!<AA A..A25A2c |i|\}}}||vr4 5||\}}}}|||dz|f||<dddn #1swxYwYn+ |i|} 5||d|f||<dddn #1swxYwY|Sr r r s rrzcache..wrapped_funcsZ+49d+Ef+E+E (J DZ''FF(2:(>%CUA.12uQw-EJz*FFFFFFFFFFFFFFFdD+F++BB.14D-AJz*BBBBBBBBBBBBBBBJs:>> A&&A*-A*c"tdSrIddlm}|tjt}|n%tj ti}|dS)Nrr) rrrrrrrrrr)session_contextrrrrs rrzcache..clears   F  < ' ' ' ' ' 'E"',,z9==>>E KKMMMM(,,Y;;E rr )rr threadingRLockr functoolswrapsrrrron_session_destroyed__dict__rDAttributeError) rVrrrrrrrrrrr rs ```````` @@@rrr1s @||~~333 Pv P P P   !rJ |         I ?  D1,1,1,1,1,1,1,1,1,1,1,1,1,f4                                  L1u|1 (D1 ))%000 $$T]3333       sD%% D21D2)NNNrNFrF)P__doc__datetimedtrrBriorpathlibrhrrrunittest unittest.mockweakref contextlibrrparam.parameterizedrrr_FFI_TYPE_NAMESrWeakKeyDictionary _HASH_STACKSr#rrbytesrfloatintbool bytearrayr4rprvrarcplatform perf_counterr monotonicr r(r1r6r9rKrRrYrlryr}slicerr=rFPathpartialmockMockStringIOBytesIOdaterismodulerr'rrrErrrrrrr rrr6s{   %%%%%% 333333 G@  (w(** 5oy"5577 3sD)TT$ZZ <7 HH~H & & & & &V & & &$$$888***LLL666 B B B =++ 77   <<   DJJ##  ; I 5$ L66 M;;["*xGKK ;!" <#$"<%&%l'(-l*K#I#I#I#I #H#H#D#D !B!B !9!9557L7L; @ DK   """,   $   ###>8=?DVVVVVVr