a Dfb;5@sdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZ ddlZddlmZddlZddlmZddlmZdZdZiZeZed efiZeee e!e"e#edfZ$d Z%d Z&d Z'd Z(e j)d kre j*Z+ne j,Z+Gd d d eZ-ddZ.ddZ/ddZ0ddZ1ddZ2ddZ3ddZ4ddZ5ddZ6d d!Z7e!e/ed"d#e d$d#e"d%d#edd&d#e8e3ee#fd'd#e9e:e;fe2ejj?d)d#ej@ejAfe7ejBd*d#d+e6d,e5d-e5d.e5d/e5d0e3d1d2d#d3d4d#d5d6d#d7d8d#ejCd9d#ejDd:d#d;d#dd?ZGd@dAZHdBdCZIdDdEZJdFdGZKdHdIZLedJdKZMdLdMZNdVdQdRZOe"dSdTdUZPdS)Wz? Implements memoization for functions with arbitrary arguments N)contextmanager)iscoroutinefunction)states.panel-93KZ39Q-floatingdangeroushomechose-CYCLE)z_cffi_backend.FFIzbuiltins.CompiledFFIZ INDETERMINATEiwin32c@s,eZdZddZddZddZddZd S) _StackcCs i|_dSN)_stackselfr [/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/panel/io/cache.py__init__<sz_Stack.__init__cCs||jt|<dSr)r idr valr r r push?sz _Stack.pushcCs|jdSr)r popitemr r r r popBsz _Stack.popcCst||jvSr)rr rr r r __contains__Esz_Stack.__contains__N)__name__ __module__ __qualname__rrrrr r r r r:srcCs t|}|j}|j}d||fS)z&Get module.type_name for a given type.z%s.%s)typerr)objZthe_typemodulenamer r r _get_fqnHsrcCs |dd}|j|dddS)NlittleT)signed) bit_lengthto_bytes)i num_bytesr r r _int_to_bytesOsr%cCs t|tSr) isinstance _NATIVE_TYPESrr r r _is_nativeSsr)cCst|totdd|DS)Ncss|]}t|VqdSr)_is_native_tuple).0vr r r Wz#_is_native_tuple..)r&tupleallr(r r r r*Vsr*cCsVtd}|tdt|jt|tr6|n|D]}|t|q:| S)Nmd5__) hashlibnewupdate_generate_hashrrr&dictitemsdigest)rhitemr r r _container_hashYs  r<cCst|j|j|jgSr)r<startstepstopxr r r _slice_hash`srBcCsBtd}|t|j|t|j|t|j|SNr1)r3r4r5r6argsfunckeywordsr9rr:r r r _partial_hashcs  rHcCsddl}t||j|jfs$||}t|tkr>|jtdd}zNt||jrxd|j | d|j |j  WSd|j | WSt ydt |t jYS0dS)Nr)nZ random_states%s)Zpandasr&ZSeriesZ DataFramelen_PANDAS_ROWS_LARGEsample_PANDAS_SAMPLE_SIZEutilZhash_pandas_objectsumcolumns TypeErrorpickledumpsHIGHEST_PROTOCOL)rpdr r r _pandas_hashjs    rVcCs^td}|t|j|jtkrHddl}|j d}|j |j t d}|| |S)Nr1r)size)r3r4r5r6shaperW_NP_SIZE_LARGEnumpyrandomZ RandomStatechoiceZflat_NP_SAMPLE_SIZEtobytesr9)rr:nprr r r _numpy_hash}s   r`cCs6td}|t||t||SrC)r3r4r5r6tellgetvaluer9rGr r r _io_hashs rccCs|Sr)encoder(r r r r.recCs tt|Sr)r%hashr(r r r rer.cCs|dur dSdS)NT10r r(r r r rer.cCsdS)Nrhr r(r r r rer.cCs|Srr r(r r r rer.cCs t|Sr)strrdr(r r r rer.cCs tt|Sr)r%rr(r r r rer.cCst|j|dS)Nzutf-8)rrrdr(r r r rer. numpy.ndarrayzpandas.core.series.Seriespandas.core.frame.DataFramezpandas.core.indexes.base.Indexz&pandas.core.indexes.numeric.Int64Indexz$pandas.core.indexes.range.RangeIndexzbuiltins.mappingproxycCs tt|Srr<r7r(r r r rer.zbuiltins.dict_itemscCs tt|Srrlr(r r r rer.zbuiltins.getset_descriptorcCs |jSr)rrdr(r r r rer.z numpy.ufunccCs |jSrrrdr(r r r rer.cCs |jSrrmr(r r r rer.cCs|jSr)rr(r r r rer.cCst|do|jdkS)Nr^r )hasattrrXr@r r r rer.cCs|Sr)r^r@r r r rer.rhcCsxt|}|tvrt|StD]R\}}t|trD||krr|Sq t|r`||rr|Sq t||r |Sq dSr)r _hash_funcsr8r&riinspect isfunction)rZfqn_typeZotype hash_funcr r r _find_hash_funcs     rsc Cst|}|durpz ||}WnNtyj}z6td|d|dt|jd|d |WYd}~n d}~00|St|drtd}z |}Wn(tytdt|jdYn0|D]}| t |q| St t |S) NzUser hash function z failed for input z with following error: z("z"). __reduce__r1zCould not hash object of type )rs BaseException ValueErrorrrrnr3r4rtr5r6r9r%r)rrroutputer:Z reduce_datar;r r r _generate_hash_inners6     rycCs@tj}||vrtS||zt|}W|n |0|Sr)rZ_current_stack_CYCLE_PLACEHOLDERrryr)rZ hash_stack hash_valuer r r r6s  r6cCs|dur dSt|st|r |St|trJtdd|Drdg|RSn>t|dkst|dkst|st|st |rt |St S)Ncss|]}t|VqdSr)r))r+r;r r r r-r.z_key..Z__listrkrj) r)r*r&listr0rrp isbuiltin isroutineiscoder_INDETERMINATEr(r r r _keys&   rcst||kr|dkr*t|d}n`|dkrbtfdd|Ddddd d}n(|d krt|d dddd}||=qd S) zs Deletes items in the cache if the exceed the number of items or their TTL (time-to-live) has expired. fiforlruc3s&|]\}\}}}}||fVqdSrr )r+k_ttimer r r-r.z!_cleanup_cache..cSs|dS)Nrr or r r rer.z _cleanup_cache..)keylfucSs |ddS)Nrr rr r r rer.N)rJlowerr|keyssortedr8)cachepolicy max_itemsrrr rr _cleanup_caches    rcCs4t|D]"\}\}}}}|||kr ||=q dS)zM Deletes items in the cache if their TTL (time-to-live) has expired. N)r|r8)rttlrrrtsr r r _cleanup_ttls rc csHtt}t|zdVWtt|ntt|0dSr)r7ror5clear) hash_funcsbackupr r r _override_hash_funcs s  rcCs|t|t|f}t|vr*|tvr*t|Std}t|4|rP|t||rb|t|Wdn1sv0Y|}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 r1N) rr _HASH_MAPr3r4rr5r6 hexdigest)rErrDkwargsrZhasherr{r r r compute_hashs  ,rLRUF./cachec sdvrtddp"idurB fddSdgt f ddtrtfd d  ntfd d  f fd d }| _rtj rtj j r|fdd} tj | z j j WntyYn0 S)a Memoizes functions for a user session. Can be used as function annotation or just directly. For global caching across user sessions use `pn.state.as_cached`. Arguments --------- func: callable The function to cache. hash_funcs: dict or None A dictionary mapping from a type to a function which returns a hash for an object of that type. If provided this will override the default hashing function provided by Panel. max_items: int or None The maximum items to keep in the cache. Default is None, which does not limit number of items stored in the cache. policy: str A caching policy when max_items is set, must be one of: - FIFO: First in - First out - LRU: Least recently used - LFU: Least frequently used ttl: float or None The number of seconds to keep an item in the cache, or None if the cache should not expire. The default is None. to_disk: bool Whether to cache to disk using diskcache. cache_dir: str Directory to cache to on disk. per_session: bool Whether to cache data only for the current session. )rrrz8Cache policy must be one of 'FIFO', 'LRU' or 'LFU', not .Nc st|dS)N)rErrrto_disk cache_path per_session)r)f)rrrrrrr r re_szcache..csj}o.tdto.ttd|d u}|}}|rtdtjrt di}tfdd|ddDdd}t |difi|}t ||}t }t j j} jd krd n| j} |r| tdjjf} n | jf} r | ttjf7} tt| } | d<tj| } | durtrbdd lm} | tj| }ni}|tj| <} durt| ||| vr| ||fSdurt| || ||fS) NrZ_dinfoc3s|]}td|VqdS)rN)getattr)r+drDr r r-vr.z+cache..hash_func..Z dependenciesr rkw__main__Index)rr&objectrrparamZ Parameterizedr/getr7r_TIME_FNsysmodulesr__file__rrcurdocr3sha256r6r_memoize_cache diskcacherospathjoinrr)rDr func_nameZ is_methodZ hash_argsZ hash_kwargsZdinfor{rrfname func_hash func_cacherr) rrE func_hashesrrrrrr wrapped_funcrr rrlsD  *          zcache..hash_funcc s|i|\}}}||vrf4||\}}}}|||d|f||<Wdq1sZ0YnH|i|IdH} ||d|f||<Wdn1s0Y|SNrrr rDrrr{rretrcountrrErrlockr r rs4.zcache..wrapped_funcc s|i|\}}}||vrf4||\}}}}|||d|f||<Wdq1sZ0YnB|i|} ||d|f||<Wdn1s0Y|Srr rrr r rs4.cs^|ddurdS|d}rDddlm}|tj|}|ntj|i}|dS)Nrr) rrrrrrrrr)rrrr)rrr r rs   zcache..clearcSs |dSrr )session_contextrr r r server_clearszcache..server_clear)rrv threadingRLockr functoolswrapsrrrrZon_session_destroyed__dict__r5AttributeError) rErrrrrrrrrr ) rrErrrrrrrrrrrr r5s2#   3     r)returncCs||upt|t|kS)z[Returns True if value and other are equal Supports complex values like DataFrames )r6)valueotherr r r is_equalsr)NNNrNFrF)Q__doc__datetimedtrr3rpiorpathlibrRrrrZunittestZ unittest.mockweakref contextlibrrZparam.parameterizedrrrzZ_FFI_TYPE_NAMESrWeakKeyDictionaryZ _HASH_STACKSrrrbytesrifloatintbool bytearrayr'rYr]rKrMplatform perf_counterr monotonicrrr%r)r*r<rBrHrVr`rcslicer|r/r7PathpartialZmockZMockStringIOBytesIOdater}ismodulerorrsryr6rrrrrrrr r r r s                    !