e4<dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZ ddlZddlmZddlZddlmZdZdZiZejZedefiZeeeee e!edfZ"d Z#d Z$d Z%d Z&e j'd kre j(Z)ne j*Z)Gd d eZ+d Z,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5iee-edede dedde6e1ee!fde7e8e9fe0ej:dej;e2e j<j=dej>ej?fe5ej@dde4d e3d!e3d"e3d#e3d$e1d%d&d'd(d)d*d+d,ejAd-ejBd.d/d0i ZCeD]ZDd1eCeD<d2ZEd3ZFd4ZGd5ZHd6ZId7ZJed8ZKd9ZL d>d=ZMdS)?z? Implements memoization for functions with arbitrary arguments N)contextmanager)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 popitemr s rpopz _Stack.pop@s rc.t||jvSr )rr rs r __contains__z_Stack.__contains__Cs#ww$+%%rN)__name__ __module__ __qualname__rrrrrrr r 8sP###&&&&&rr cJt|}|j}|j}|d|S)z&Get module.type_name for a given type..)typerr)objthe_typemodulenames r_get_fqnr'Fs.CyyH  F  Dffdd ##rcf|dzdz}||ddS)NlittleT)signed) bit_lengthto_bytes)i num_bytess r _int_to_bytesr0Ms1!#)I ::i$: 7 77rc,t|tSr ) isinstance _NATIVE_TYPESr#s r _is_nativer5Qs c= ) ))rc^t|totd|DS)Nc34K|]}t|VdSr )_is_native_tuple).0vs r z#_is_native_tuple..Us+)K)K!*:1*=*=)K)K)K)K)K)Kr)r2tupleallr4s rr8r8Ts. c5 ! ! Kc)K)Ks)K)K)K&K&KKrc`tjd}|tdt |jt |tr|n|D]$}|t|%| S)Nmd5__) hashlibnewupdate_generate_hashr"rr2dictitemsdigest)r#hitems r_container_hashrJWs EAHH^5c!355 6 6777 *3 5 5>3'' %%&&&& 88::rcDt|j|j|jgSr )rJstartstepstopxs r _slice_hashrQ^s AGQVQV4 5 55rc<tjd}|t|j|t|j|t|j|SNr?)rArBrCrDargsfunckeywordsrGr#rHs r _partial_hashrXass 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)pandasr2Series DataFramelen_PANDAS_ROWS_LARGEsample_PANDAS_SAMPLE_SIZEutilhash_pandas_objectsum TypeErrorpickledumpsHIGHEST_PROTOCOL)r#pds r _pandas_hashrkhs 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)rArBrCrDshaperm_NP_SIZE_LARGEnumpyrandom RandomStatechoiceflat_NP_SAMPLE_SIZEtobytesrG)r#rHnprs r _numpy_hashrxws EAHH^CI & &''' x>!! %%a((el38/:::HHS[[]] 88::rc"tjd}|t||t||SrS)rArBrCrDtellgetvaluerGrWs r_io_hashr|sc EAHH^CHHJJ ' '(((HH^CLLNN + +,,, 88::rc*|Sr )encoder4s rrsszz||rc:tt|Sr )r0hashr4s rrrs}T#YY77rc|durdndS)NT10rr4s rrrssd{{ttrcdS)Nrrr4s rrrstrc|Sr rr4s rrrsSrcDt|Sr )strr~r4s rrrsSXX__%6%6rc:tt|Sr )r0rr4s rrrs]2c77%;%;rcXt|j|dS)Nzutf-8)r"rr~r4s 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 rJrEr4s rrrtCyy/I/Irzbuiltins.dict_itemsc:tt|Sr rr4s rrrrrzbuiltins.getset_descriptorc4|jSr )rr~r4s rrrss/?/F/F/H/Hrz numpy.ufuncc4|jSr rr~r4s rrrss|/B/B/D/Drc4|jSr rr4s rrrsS\-@-@-B-Brc|jSr )rr4s rrrsS\rc8t|do |jdkS)Nrvr)hasattrrnrOs rrrsga##52 rc*|Sr )rvrOs rrrsrrc>t|}|tvr t|StD]]\}}t|tr ||kr|cS%t j|r||r|cSIt||r|cS^dSr )r' _hash_funcsrFr2rinspect 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"rrrArBrrCrDrGr0r)r#routputerH reduce_datarIs 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 rrDrDsn%J j!!OOC)#..   s AA(c|dSt|st|r|St|tr t d|Drdg|RSnqt |dksOt |dks.s*00Dz$000000r__listrr) r5r8r2listr=r'r isbuiltin isroutineiscoder_INDETERMINATEr4s 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)r9k_ttimes rr;z!_cleanup_cache..s7KK/!\aAq1d1f+KKKKKKrc|dS)Nrros rrz _cleanup_cache..s qtr)keylfuc|ddS)Nrrrs rrz _cleanup_cache..sad1grN)r_lowerrkeyssortedrF)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)rrF)rttlrrrtss r _cleanup_ttlrsO#5;;==11]aQ Gs??c rc#FKtt}t| dVtt|dS#tt|wxYwr )rErrCclear) 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_MAPrArBrrCrD hexdigest)rUrrTkwargsrhasherrs 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  dvrtddpi fdSd}tj t j  f d dfd } | _r.Vs(!!    rcl 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=| ||| vr55| |\}}}}|||dz|f| |<|cdddS#1swxYwYt?| |i|}5||d|f| |<dddn #1swxYwY|S) Nr_dinfoc3DK|]}td|VdS)rN)getattr)r9drTs rr;z.cache..wrapped_func..ns1YYagd1gq11YYYYYYr dependenciesrrkw__main__Index) rr2objectrr"param Parameterizedr<getrEr_TIME_FNsysmodulesr__file__ func_hashrrcurdocrAsha256rDr_memoize_cache diskcacherospathjoinrr)rTr func_name is_method hash_args hash_kwargsdinforrr%fname func_cacherrretrcountrrrUrlockr per_sessionrrr wrapped_funcs` rr zcache..wrapped_funcbsgM  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$ / / /  # #  $.z$:!R*-r57D)A :&                  :vy$ ? ? ?dD#F##  : :&)4D%9Jz " : : : : : : : : : : : : : : : s$I**I.1I. J))J-0J-c"tdSrIddlm}|tjt}|n%tj ti}|dS)Nrr) rrrrrrrrrr)session_contextrrrrs rrzcache..clears   F  < ' ' ' ' ' 'E"',,z9==>>E KKMMMM(,,Y;;E rr )rr threadingRLock functoolswrapsrrrr on_session_destroyed__dict__rCAttributeError) rUrrrrrrrrrrr s ```````` @@rrr/s@||~~333 Pv P P P   !rJ |         I ?  D_T77777777777777r       L1u|1 (D1 ))%000 $$T]3333       s C-- C:9C:)NNNrNFrF)N__doc__datetimedtrrAriorpathlibrgrr runittest unittest.mockweakref contextlibrrrr_FFI_TYPE_NAMESrWeakKeyDictionary _HASH_STACKSr"rrbytesrfloatintbool bytearrayr3rorur`rbplatform perf_counterr monotonicr r'r0r5r8rJrQrXrkrxr|slicerr<rEPathpartialmockMockStringIOBytesIOdaterismodulerr&rrrDrrrrrrrrrr0si   %%%%%%  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=?DBBBBBBr