&ew UdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZddlmZddlZddlmZmZm Z ddl!m"Z"dd l#m$Z$dd l%m&Z&dd l'm(Z(dd l)m*Z*dd l+m,Z,ddl-m.Z.m/Z/ddl0m1Z1m2Z2m3Z3ddl4m5Z5ddl6m7Z7m8Z8ddl9m:Z:ddl;me j?Z@e dddgZAe ddgZBide.jCde.jCde.jCde.jCde.jCde.jCde.jCde.jCd e.jCd!e.jCd"e.jCd#e.jCd$e.jCd%e.jCd&e.jCd'e.jCd(e.jCid)e.jCd*e.jCd+e.jCd,e.jCd-e.jCd.e.jCd/e.jCd0e.jCd1e.jCd2e.jCd3e.jCd4e.jCd5e.jCd6e.jCd7e.jCd8e.jDd9e.jDid:e.jDd;e.jDde.jDd?e.jDd@e.jDdAe.jDdBe.jDdCe.jDdDe.jDdEe.jDdFe.jDdGe.jDdHe.jDdIe.jDdJe.jDdKe.jDiZEeeFe.feGdL<dMedNeFfdOZHeGdPdQZIGdRdSe8ZJeJZKGdTdUe jLZMeMZNejOdVedWefdNedfdXZPejOdNedfdYZQdZd[d\eFd]edWefdNdfd^ZRdZd[d\eFdNdfd_ZSd`eIdaeFdbeTdcedWefddee1dNef deZUd`eIdaeFdedbeTdcedWefddee1dNdfdfZVdedcedWefddee1dNeWfdgZXdaeFdNefdhZYdaeFdedNdfdiZZ dd`eIdaeFdjeTdbeTdcedWefddee1dNefdkZ[e5dl dd`eIdaeFdedjeTdbeTdcedWefddee1fdmZ\ednedWefoZ]e ddVe]djeTdbeTdreTdseTddee1dtee^duee_dNe]fdvZ`e ddVddjeTdbeTdreTdseTddee1dtee^duee_dNee]ge]ffdwZ` ddVee]djeTdbeTdreTdseTddee1dtee^duee_dNeee]ge]fe]ffdxZ`dVedWefddee1dNeFfdyZadNeTfdzZbdNeFfd{ZcdNeTfd|Zddd}ZeGd~defZgGddefZhGddeiZjGdde(ZkGdde(ZldVedWefdNeFfdZmdS)zA library of caching utilities.N) namedtuple) dataclass) AnyCallableDictIteratorListOptionalTypeVarUnioncastoverload)TTLCache)config file_utilutil)show_deprecation_warning)spinner)handle_uncaught_app_exception)StreamlitAPIWarning) get_logger)CACHE_DOCS_URL) CacheTypeget_decorator_api_name) HashFuncsDict HashReason update_hash)gather_metrics) CacheStatCacheStatsProvider)HASHLIB_KWARGS)asizeof _CacheEntryvaluehash_DiskCacheEntrystrfloatintbytesboolzdatetime.datetimezpandas.DataFramez pandas.Seriesz numpy.bool_z numpy.bool8z numpy.ndarrayz numpy.float_z numpy.float16z numpy.float32z numpy.float64z numpy.float96znumpy.float128z numpy.int_z numpy.int8z numpy.int16z numpy.int32z numpy.int64z numpy.intpz numpy.uint8z numpy.uint16z numpy.uint32z numpy.uint64z numpy.uintpzPIL.Image.Imagezplotly.graph_objects.Figurezmatplotlib.figure.Figurez altair.Chartzpyodbc.Connectionz pymongo.mongo_client.MongoClientzmysql.connector.MySQLConnectionzpsycopg2.connectionzpsycopg2.extensions.connectionz2snowflake.connector.connection.SnowflakeConnectionz#snowflake.snowpark.sessions.Sessionzsqlalchemy.engine.base.Enginezsqlite3.Connectionztorch.nn.Moduleztensorflow.keras.Modelztensorflow.Moduleztensorflow.compat.v1.Sessionztransformers.Pipelinez transformers.PreTrainedTokenizerz$transformers.PreTrainedTokenizerFastz$transformers.PreTrainedTokenizerBaseztransformers.PreTrainedModelztransformers.TFPreTrainedModelz transformers.FlaxPreTrainedModelNEW_CACHE_FUNC_RECOMMENDATIONS cached_valuereturnct|j}t|}|d|dt |dt dSdt dS)zcBuild a deprecation warning string for a cache function that has returned the given value. Nz`st.cache` is deprecated. Please use one of Streamlit's new caching commands, `st.cache_data` or `st.cache_resource`. Based on this function's return value of type `z`, we recommend using `st.z#`. More information [in our docs](z).z`st.cache` is deprecated. Please use one of Streamlit's new caching commands, `st.cache_data` or `st.cache_resource`. More information [in our docs]()type __qualname__r,getrr)r-typenamecache_type_recs Hlib/python3.11/site-packages/streamlit/runtime/legacy_caching/caching.py_make_deprecation_warningr6sL!!.H377AAN! A  A AD!AD!!D%(D%NcT|j5i|_ddddS#1swxYwYdS)zClear all cachesN)rFrGrHs r5clearz_MemCaches.clearsv Z ' '$&D ! ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's !!c|j5|j}dddn #1swxYwYd|D}|S)Nc hg|]/}|jD]%}td|jt|&0S)st_cache)r:rr;r").0r:cs r5 z(_MemCaches.get_stats..sV   [   j%"4gajj A A    r7)rFrGcopyvalues)rIfunction_cachesstatss r5 get_statsz_MemCaches.get_statss Z ; ;#388::O ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;   (//11     s .22)rPr.N)r<r=r1__doc__rJr'rNr r(r9r`rbr rrmr?r7r5rArAs//888  #     ++ +e_+e_ +  +  ++++Z'''' 4 ?      r7rAc eZdZdZdefdZdS)ThreadLocalCacheInfoc"g|_d|_dS)Nr)cached_func_stacksuppress_st_function_warningrHs r5rJzThreadLocalCacheInfo.__init__s;=,-)))r7r.c*tj|SrCrLrHs r5rNzThreadLocalCacheInfo.__repr__rOr7Nr<r=r1rJr'rNr?r7r5rqrqs>... #      r7rqfunc.c#Ktj| dVtjdS#tjwxYwrC) _cache_inforsappendpoprws r5_calling_cached_functionr}sa!((..., %))+++++ %))++++s A A'c#Ktxjdz c_ dVtxjdzc_tjdksJdS#txjdzc_tjdksJwxYw)Nr)ryrtr?r7r5#suppress_cached_st_function_warningrs,,1,,= 00A50071<<<<<< 00A50071<<<<<<< > Qs&AA Acttjdkr5tjdkr'tjd}t |||dSdSdS)aIf appropriate, warn about calling st.foo inside @cache. DeltaGenerator's @_with_element and @_widget wrappers use this to warn the user when they're calling st.foo() from within a function that is wrapped in @st.cache. Parameters ---------- dg : DeltaGenerator The DeltaGenerator to publish the warning to. st_func_name : str The name of the Streamlit function that was called. rN)lenryrsrtr)rrrs r5%maybe_show_cached_st_function_warningrs[& K )**Q..  4 9 9!3B7 (\;GGGGG /. 9 9r7r^rQallow_output_mutation func_or_code hash_funcsc|j}||vr||}|sSt|j||}|j}||kr0td|t |j|tdt|j|jStd|td)NzCached object was mutated: %szMemory cache HIT: %szMemory cache MISS: %szKey not found in mem cache) r:_get_output_hashr$r%r[r\CachedObjectMutationErrorr0CacheKeyNotFoundError) r^rQrrrr:entrycomputed_output_hashstored_output_hashs r5_read_from_mem_cacher8s OE e||c $ K#3 \:$$ "' #'999 =sCCC/ \JJJ ,d5;.?.?@@@{  -s333#$@AAAr7c|rd}nt|||}|jd|j|_t |||j|<dS)N.)r$r%)rr=r1r;r#r:)r^rQr$rrrr%s r5_write_to_mem_cacherUs`A|Z@@ , 7UU,:SUUI&U>>>IOCr7ctjdit}t|||tj||S)Nmd5hasherr hash_reason hash_source)r)hashlibnewr!rrCACHING_FUNC_OUTPUTdigest)r$rrrs r5rrfsR[ 1 1. 1 1F 2  ==??r7ctjdd|z} tj|d5}tj|}|j}t dt|dddn #1swxYwYn[#tj $r1}t |td|zd}~wt$rtdwxYw|S)Nr: %s.pickleTbinaryzDisk cache HIT: %szUnable to read from cache: %szKey not found in disk cache)rget_streamlit_file_pathstreamlit_readpickleloadr$r[r\r0rErrorerror CacheErrorFileNotFoundErrorr)rQpathinputrr$rs r5_read_from_disk_cacherts,  ,WkC6G H HD C  %d4 8 8 8 =EK&&EKE MM.U < < < = = = = = = = = = = = = = = = :>>> a81<=== CCC#$ABBBC Ls;B AB4 B BB BB C$,CC$ctjdd|z} tj|d5}t|}t j||tjddddS#1swxYwYdS#tj$rd}t | tj |n#tttf$rYnwxYwt!d|zd}~wwxYw)Nr:rTr)r$zUnable to write to cache: %s)rrstreamlit_writer&rdumpHIGHEST_PROTOCOLrrr[r\osremoverIOErrorOSErrorr)rQr$routputrrs r5_write_to_disk_cachersU  ,WkC6G H HD =  &tD 9 9 9 @V#%000E Kvv'> ? ? ? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ :=== a  IdOOOO!7G4    D 7!;<<<=s^A;1A.! A;.A22A;5A26A;;C. C)%B:9C):CC)CC))C.persistc  t|||||S#t$r-}tt||jcYd}~Sd}~wt $r3}|r*t |}t|||||||cYd}~S|d}~wwxYw)zRead a value from the cache. Our goal is to read from memory if possible. If the data was mutated (hash changed), we show a warning. If reading from memory fails, we either read from disk or rerun the code. N)rrrCachedObjectMutationWarningr-rrr)r^rQrrrrrr$s r5_read_from_cachers# s1<    %%&A!&D&DEEE~   )#..E 3'>> import streamlit as st >>> >>> @st.cache ... def fetch_and_clean_data(url): ... # Fetch data from URL here, and then clean it up. ... return data ... >>> d1 = fetch_and_clean_data(DATA_URL_1) >>> # Actually executes the function, since this is the first time it was >>> # encountered. >>> >>> d2 = fetch_and_clean_data(DATA_URL_1) >>> # Does not execute the function. Instead, returns its previously computed >>> # value. This means that now the data in d1 is the same as in d2. >>> >>> d3 = fetch_and_clean_data(DATA_URL_2) >>> # This is a different URL, so the function executes. To set the ``persist`` parameter, use this command as follows: >>> @st.cache(persist=True) ... def fetch_and_clean_data(url): ... # Fetch data from URL here, and then clean it up. ... return data To disable hashing return values, set the ``allow_output_mutation`` parameter to ``True``: >>> @st.cache(allow_output_mutation=True) ... def fetch_and_clean_data(url): ... # Fetch data from URL here, and then clean it up. ... return data To override the default hashing behavior, pass a custom hash function. You can do that by mapping a type (e.g. ``MongoClient``) to a hash function (``id``) like this: >>> @st.cache(hash_funcs={MongoClient: id}) ... def connect_to_database(url): ... return MongoClient(url) Alternatively, you can map the type's fully-qualified name (e.g. ``"pymongo.mongo_client.MongoClient"``) to the hash function instead: >>> @st.cache(hash_funcs={"pymongo.mongo_client.MongoClient": id}) ... def connect_to_database(url): ... return MongoClient(url) zEntering st.cache: %sNfr.c 2t|S)Nrr:)rrrrRrrrrSs r5wrapperzcache..wrapperQs2&;)$7%'    r7c  tjds"td iS j}t dkrt dkrd|z}nd|z} f d} r5t |d5|cd d d S#1swxYwYd S|S) zWrapper function that only calls the underlying function on a cache miss. Cached objects are stored in the cache/ directory. zclient.cachingzPurposefully skipping cacherzRunning `%s()`.zRunning `%s(...)`.c V t t }tjd}rt |t j rt |t j |}|d}t d| t||  }t d n#t$rt d t 5 r/t5 i}dddn #1swxYwYn i}dddn #1swxYwYt|||  YnwxYwt!t#||S) Nrr-z Cache key: %s)r^rQrrrrz Cache hit: %szCache miss: %sr) _hash_func _mem_cachesr`rrrrCACHING_FUNC_ARGS hexdigestr[r\rrr}rrrr6)r^ value_hasher value_key return_valuerargs cache_keyrkwargsrRnon_optional_funcrrrSs r5get_or_create_cached_valuez?cache..wrapped_func..get_or_create_cached_valuevs ''8*EE $--icJJI#;u--L ') * < 1  ') * < 1 %..00I$-99ii8I MM/9 5 5 5 /'!#*?!2)      o/@AAAA(    .0ABBB-.?@@JJ*J@BBNN+<+|%L%L M M M sZ;0C,,4F  E&1 E: E&E E& E  E& F &E* *F -E* .F  F TrN)r get_optionr[r\r1rr)rrnamemessagerrrrrRrrrrrSs`` r5 wrapped_funczcache..wrapped_funcdst !122 6 MM7 8 8 8$$d5f55 5 - t99>>c&kkQ..'$.GG*T1GR R R R R R R R R R R R R R h  0--- 4 41133 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4.-// /s B**B.1B.) r[r\r functoolswraps__dict__updateAttributeErrorr ) rwrrrrrrRrSrrrrs ``````` @@r5r:r:sBH MM)4000 | q Q            !I_&''i0i0i0i0i0i0i0i0i0i0i0i0('i0Z $$%6%?@@@@       <  s/B BBc4tjd}t|j|jf|dt j|t|||t j||}t d|j|j||S)Nrrzmem_cache key for %s.%s: %s) rrrr=r1rCACHING_FUNC_BODYrr[r\)rwr func_hasherrs r5rrs$+e$$K $+,0  0 %%''I MM%t8I9 r7c:ttS)zClear the memoization cache. Returns ------- boolean True if the disk cache was cleared. False otherwise (e.g. cache file doesn't exist on disk). )_clear_mem_cache_clear_disk_cacher?r7r5 clear_cachers   r7c*tjdS)Nr:)rrr?r7r5get_cache_pathrs  ,W 5 55r7ct}tj|rt j|dSdS)NTF)rrrisdirshutilrmtree) cache_paths r5rrs? !!J w}}Z   j!!!t 5r7c8tdSrC)rrbr?r7r5rr)sr7ceZdZdS)rNr<r=r1r?r7r5rr-Dr7rceZdZdS)rNrr?r7r5rr1rr7rc eZdZdZdefdZdS)rcv||_tj|r d|_dSt ||_dS)Nz a code block)r-inspectiscodecached_func_name_get_cached_func_name_md)rIr-rs r5rJz"CachedObjectMutationError.__init__9sA( >, ' ' K$2D ! ! !$<\$J$JD ! ! !r7r.c*tj|SrCrLrHs r5rNz"CachedObjectMutationError.__repr__@rOr7Nrvr?r7r5rr5sAKKK #      r7rc$eZdZfdZdZxZS)rc|||}tt||dSrC) _get_messagesuperrrJ)rIrrmsg __class__s r5rJz CachedStFunctionWarning.__init__Es= k:: %t,,55c:::::r7c\d|zt|d}d|zdS)Nz`st.%s()` or `st.write()`)r func_namea Your script uses %(st_func_name)s to write to your Streamlit app from within some cached code at %(func_name)s. This code will only be called when we detect a cache "miss", which can lead to unexpected results. How to fix this: * Move the %(st_func_name)s call outside %(func_name)s. * Or, if you know what you're doing, use `@st.cache(suppress_st_warning=True)` to suppress the warning.  )rstrip)rIrrrs r5rz$CachedStFunctionWarning._get_messageIsB7,F1+>>     %++ r7r<r=r1rJr __classcell__r s@r5rrDsG;;;;;r7rc$eZdZfdZdZxZS)rc||}tt||dSrC)rrrrJ)rIorig_excr r s r5rJz$CachedObjectMutationWarning.__init___s;)) )40099#>>>>>r7c@dd|jizdS)Na7 Return value of %(func_name)s was mutated between runs. By default, Streamlit's cache should be treated as immutable, or it may behave in unexpected ways. You received this warning because Streamlit detected that an object returned by %(func_name)s was mutated outside of %(func_name)s. How to fix this: * If you did not mean to mutate that return value: - If possible, inspect your code to find and remove that mutation. - Otherwise, you could also clone the returned value so you can freely mutate it. * If you actually meant to mutate the return value and know the consequences of doing so, annotate the function with `@st.cache(allow_output_mutation=True)`. For more information and detailed solutions check out [our documentation.] (https://docs.streamlit.io/library/advanced-features/caching) r r )rr)rIrs r5rz(CachedObjectMutationWarning._get_messagecs+ $H56% 7& %++) r7rrs@r5rr^sG?????r7rc:t|dr d|jzSdS)z1Get markdown representation of the function name.r<z`%s()`za cached function)hasattrr<r|s r5rr{s'tZ  #$-''""r7rC)FFTFNNN)NFFTFNNNrn)nro contextlibrrrrWrrrrDtime collectionsr dataclassesrtypingrrrrr r r r r r cachetoolsr streamlitstrrrstreamlit.deprecation_utilrstreamlit.elements.spinnerrstreamlit.error_utilrstreamlit.errorsrstreamlit.loggerrstreamlit.runtime.cachingr$streamlit.runtime.caching.cache_typerr(streamlit.runtime.legacy_caching.hashingrrrstreamlit.runtime.metrics_utilrstreamlit.runtime.statsrr streamlit.utilr! streamlit.vendor.pympler.asizeofr"r<r[ monotonicr]r#r&DATARESOURCEr,r'r>r6r9rArlocalrqrycontextmanagerr}rrrr+rrr*rrrrrrr)r(r:rrrrr Exceptionrr ValueErrorrrrrr?r7r5r3s &%%  """"""!!!!!!                         ----------??????......>>>>>>000000''''''444444RRRRRRRR :99999AAAAAAAA))))))444444 *X  .j&(9:: *. ::78 9>78 Y^78 9> 78  Y^ 78  IN 7878 78Y^789>789>78Y^78IN78Y^78Y^78 Y^!78"Y^#78$in%7878&).'78().)78*9>+78,9>-78.9>/780).17829>3784IN5786IN7788IN978:9>;78<y~=78>"9>?78@ A78BINC78F+G78H' (:I787878J&y'9K78L9-M78N%i&8O78P9):LQ78R*9+=S78T$Y%7U78V),W78Xy)Y78Zi0[78\+]78^#I$6_78`Y/a78b' (:c78d+I,>e78f+I,>g78h#I$6i78j%i&8k7878l' (:m7878S)^ 4777tCC.   HHHHH#HHHXjll      9?   #"$$  ,8CH#5,(4.,,,, =Xd^==== +  #s(#     H+H;>H HHHH4BB B B38$ B ' B  BBBB:?? ? ? ? 38$ ? ' ? ????"   &sCx0 >F}>U       s s     =c=#=$====0+/    38$  '  B  +/ ) ) )  )  ) )  ) 38$ )' ) ) )!  )  GCxS)*** "' %*.!%            ' #  %       "' %*.!%            ' #  % qc1f     "' %*.!%q!q! 1+q! q! q! q!  q! ' q!#q! %q! 8QCF Q q!q!q!q!h0Xc3h'0Xm5L0QT0000f T    666664             I            14"5:#8CH#5########r7