chnN%SSKJr SSKrSSKrSSKrSSKrSSKJrJr SSK J r SSK J r J r Jr SSKJr SSKJr SSKJr SS KJr SS KJrJr SS KJr SS KJr SS KJr SSK J!r! SSK"J#r# SSK$J%r%J&r&J'r'J(r(J)r) SSK*J+r+J,r, SSK-J.r. SSK/J0r0 \ (a$SSK1J2r2 SSK3J4r4 SSK5J6r6 SSK7J8r8 SSK9J:r: SSK;JS'\R~S:XaSOSr@S\>S'\"\A5rBS\>S '"S!S"\C5rD\"S#S$9"S%S&55rE"S'S(\ 5rF"S)S*\5rG"S+S,5rHg)-) annotationsN) dataclassfield)Enum) TYPE_CHECKINGFinal NamedTuple)LocalComponentRegistry) get_logger) ForwardMsg) AppSession)get_data_cache_stats_provider!get_resource_cache_stats_provider)LocalDiskCacheStorageManager)MediaFileManager)MemorySessionStorage) ScriptData) ScriptCache)ActiveSessionInfo SessionClientSessionClientDisconnectedErrorSessionManagerSessionStorage)SCRIPT_RUN_WITHOUT_ERRORS_KEYSessionStateStatProvider) StatsManager)WebsocketSessionManager) Awaitable)BaseComponentRegistry)BackMsg)CacheStorageManager)MediaFileStorage)UploadedFileManager<rSCRIPT_RUN_CHECK_TIMEOUTwin32g?_SIGNAL_CHECK_INTERVAL_LOGGERc\rSrSrSrSrg)RuntimeStoppedErrorIz;Raised by operations on a Runtime instance that is stopped.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r,lC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\streamlit/runtime/runtime.pyr*r*IsEr3r*T)frozenc\rSrSr%SrS\S'S\S'S\S'S \S '\"\S 9rS \S '\"\ S 9r S\S'\ r S\S'\"\ S 9rS\S'SrS\S'Srg) RuntimeConfigMz$Config options for StreamlitRuntime.str script_path str | None command_liner"media_file_storager#uploaded_file_manager)default_factoryr!cache_storage_managerrcomponent_registryztype[SessionManager]session_manager_classrsession_storageFboolis_hellor,N)r-r.r/r0r1__annotations__rrr@r rArrBrrCrEr2r,r3r4r7r7Ms.)(/.2742. 16.1- 3J/I', >}}r3cURSL$)a True if the singleton Runtime instance has been created. When a Streamlit app is running in "raw mode" - that is, when the app is run via `python app.py` instead of `streamlit run app.py` - the Runtime will not exist, and various Streamlit functions need to adapt. N)r[r^s r4existsRuntime.existss}}D((r3c^[Rb [S5eU[lSUlSUlUR UlURUl[RUl URUl URUl[!UR"S9UlUR&Ul[+5UlUR/UR0URUR,UR2S9Ul[75UlUR8R;[=55 UR8R;[?55 UR8R;UR5 UR8R;[AUR455 g)zCreate a Runtime instance. It won't be started yet. Runtime is *not* thread-safe. Its public methods are generally safe to call only on the same thread that its event loop runs on. Parameters ---------- config Config options. Nz Runtime instance already exists!)storage)rCr> script_cachemessage_enqueued_callback)!rYr[r] _async_objs_loop_coroutine_taskr:_main_script_pathrE _is_hellorHrJ_staterA_component_registryr>_uploaded_file_mgrrr=_media_file_mgrr@_cache_storage_managerr _script_cacherBrC_enqueued_some_message _session_mgrr _stats_mgrregister_providerrrr)selfconfigs r4__init__Runtime.__init__sR    (AB B 15@D!!'!3!3"** $*#<#< "(">">/8Q8QR&,&B&B#(]"88"22"&"9"9++&*&A&A 9 '. ))*G*IJ ))*K*MN ))$*A*AB ))*B4CTCT*UVr3cUR$N)rmrws r4state Runtime.states {{r3cUR$r|)rnr}s r4rARuntime.component_registrys'''r3cUR$r|)ror}s r4uploaded_file_mgrRuntime.uploaded_file_mgrs&&&r3cUR$r|)rqr}s r4r@Runtime.cache_storage_managers***r3cUR$r|)rpr}s r4media_file_mgrRuntime.media_file_mgrs###r3cUR$r|)rur}s r4 stats_mgrRuntime.stats_mgrs r3c6UR5R$)z?A Future that completes when the Runtime's run loop has exited.)_get_async_objsrWr}s r4rWRuntime.stoppeds##%---r3cXURRU5nUcgUR$)zGet the SessionClient for the given session_id, or None if no such session exists. Notes ----- Threading: SAFE. May be called on any thread. N)rtget_active_session_infoclientrw session_id session_infos r4 get_clientRuntime.get_clients/((@@L  """r3cvURRU5nUbURR5 gg)ziClear the user_info for the given session_id. Notes ----- Threading: SAFE. May be called on any thread. N)rtget_session_infosessionclear_user_infors r4clear_user_info_for_session#Runtime.clear_user_info_for_sessions7((99*E  #  0 0 2 $r3c # [[R"5[R"5[R"5[R"5[R"5[R"5S9nXl[R "UR5SS9UlURIShvN gN7f)zStart the runtime. This must be called only once, before any other functions are called. When this coroutine returns, Streamlit is ready to accept new sessions. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. )rRrSrTrUrVrWzRuntime.loop_coroutine)nameN) rPasyncioget_running_loopEventFutureri create_task_loop_coroutinerjrVrw async_objss r4start Runtime.starts"..0mmo"==?"==?NN$NN$  &$+$7$7  ")A% !    sB>CCCcp^^TR5mSUU4SjjnTRRU5 g)zRequest that Streamlit close all sessions and stop running. Note that Streamlit won't stop running immediately. Notes ----- Threading: SAFE. May be called from any thread. c>TR[R[R4;ag[R S5 TR [R5 TRR5 g)NzRuntime stopping...) rmrHrMrNr(debug _set_staterSset)rrwsr4stop_on_eventloop'Runtime.stop..stop_on_eventloopAsT{{|44l6J6JKK MM/ 0 OOL11 2  $ $ &r3NreturnNone)rrRcall_soon_threadsafe)rwrrs` @r4stop Runtime.stop6s4))+  ' ' 112CDr3c8URRU5$)zpTrue if the session_id belongs to an active session. Notes ----- Threading: SAFE. May be called on any thread. )rtis_active_session)rwrs r4rRuntime.is_active_sessionKs  22:>>r3cU(aU(a [S5eUR[R[R4;a[ SURS35eUR RU[URUR5UUUS9nUR[R5 UR5RR5 U$)aCreate a new session (or connect to an existing one) and return its unique ID. Parameters ---------- client A concrete SessionClient implementation for communicating with the session's client. user_info A dict that contains information about the session's user. For now, it only (optionally) contains the user's email address. { "email": "example@example.com" } existing_session_id The ID of an existing session to reconnect to. If one is not provided, a new session is created. Note that whether the Runtime's SessionManager supports reconnecting to an existing session depends on the SessionManager that this runtime is configured with. session_id_override The ID to assign to a new session being created with this method. Setting this can be useful when the service that a Streamlit Runtime is running in wants to tie the lifecycle of a Streamlit session to some other session-like object that it manages. Only one of existing_session_id and session_id_override should be set. Returns ------- str The session's unique string ID. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. z`Only one of existing_session_id and session_id_override should be set. This should never happen.zCan't connect_session (state=))r script_data user_infoexisting_session_idsession_id_override)r]rmrHrMrNr*rtconnect_sessionrrkrlrrLrrTr)rwrrrrrs r4rRuntime.connect_sessionTsT #6,  ;;<00,2F2FG G%(Edkk]RS&TU U&&66"4#9#94>>J 3 3 7   CCD --113r3cP[RS5 URUUUUS9$)zCreate a new session (or connect to an existing one) and return its unique ID. Notes ----- This method is simply an alias for connect_session added for backwards compatibility. z:create_session is deprecated! Use connect_session instead.)rrrr)r(warningr)rwrrrrs r4create_sessionRuntime.create_sessions5 TU## 3 3 $  r3cURRU5nU(aURRU5 UR5 g)aClose and completely shut down a session. This differs from disconnect_session in that it always completely shuts down a session, permanently losing any associated state (session state, uploaded files, etc.). This function may be called multiple times for the same session, which is not an error. (Subsequent calls just no-op.) Parameters ---------- session_id The session's unique ID. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. N)rtr close_session_on_session_disconnectedrs r4rRuntime.close_sessions=&((99*E     + +J 7 %%'r3cURRU5nU(aURRU5 UR5 g)aDisconnect a session. It will stop producing ForwardMsgs. Differs from close_session because disconnected sessions can be reconnected to for a brief window (depending on the SessionManager/SessionStorage implementations used by the runtime). This function may be called multiple times for the same session, which is not an error. (Subsequent calls just no-op.) Parameters ---------- session_id The session's unique ID. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. N)rtrdisconnect_sessionrrs r4rRuntime.disconnect_sessions=&((@@L     0 0 < %%'r3c2UR[R[R4;a[ SURS35eUR R U5nUc[RSU5 gURRU5 g)zSend a BackMsg to an active session. Parameters ---------- session_id The session's unique ID. msg The BackMsg to deliver to the session. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. zCan't handle_backmsg (state=rNz3Discarding BackMsg for disconnected session (id=%s)) rmrHrMrNr*rtrr(rrhandle_backmsg)rwrmsgrs r4rRuntime.handle_backmsgs ;;<00,2F2FG G%(DT[[MQR&ST T((@@L   MMEz  ++C0r3c2UR[R[R4;a[ SURS35eUR R U5nUc[RSU5 gURRU5 g)zHandle an Exception raised during deserialization of a BackMsg. Parameters ---------- session_id The session's unique ID. exc The Exception. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. z6Can't handle_backmsg_deserialization_exception (state=rNz=Discarding BackMsg Exception for disconnected session (id=%s)) rmrHrMrNr*rtrr(rrhandle_backmsg_exception)rwrexcrs r4(handle_backmsg_deserialization_exception0Runtime.handle_backmsg_deserialization_exceptions ;;<00,2F2FG G%H UVW ((@@L   MMO  55c:r3c# UR[R[R[R4;agg7f)N)Tok)F unavailable)rmrHrJrMrNr}s r4is_ready_for_browser_connection'Runtime.is_ready_for_browser_connections9 ;;   ! !    #sAAc# [[URUR5URUR UR SS0S9nURS5 [R"5n[UR;at[R"5U- [:aT[R"S5IShvN [UR;a"[R"5U- [:aMT[UR;aUR5 gUR[nU(aSOSnX44UR5 $N!UR5 f=f7f) a Load and execute the app's script to verify it runs without an error. Returns ------- (True, "ok") if the script completes without error, or (False, err_msg) if the script raises an exception. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. emailztest@example.com)rr>rgrhrNg?)Ftimeoutrerror)r rrkrlrorrrs request_reruntime perf_counterr session_stater%rsleepshutdown)rwrnowrrs r4does_script_run_without_error%Runtime.does_script_run_without_errors*"4#9#94>>J"&"9"9++&*&A&A 23     ! !$ '##%C-W5J5JJ&&(3.2JJmmC(((.W5J5JJ&&(3.2JJ-G4I4II'     &&'DEB$'C7    )    sCA E+A3EE8E=EE+# EE+EE((E+cR[RSURU5 Xlg)NzRuntime state: %s -> %s)r(rrm)rw new_states r4rRuntime._set_stateHs /iH r3c# UR5nUR[R:Xa UR [R 5 O7UR[R :XaO[SUR35eURRS5 URR5(GdxUR[R :Xa[R"[R"URR55[R"URR554[R ["S9IShvN up#UHnUR%5 M U(d ["bMOUR[R :XaUR&R)5 UR*R-5HVnUR.R15nUH3nUR3XW5 [R:"S5IShvN M5 MX [R:"S5IShvN OO[R"[R"URR55[R"UR&R554[R ["S9IShvN up#UHnUR%5 M U(d ["bGMvURR5(dGMxUR*R=5H2nUR*R?UR.R85 M4 UR [R@5 URBRS5 gGN`![4a3 UR*R7UR.R85 GNf=fGNGNGN'![DaOn URBRGU 5 [HRJ"5 [LROS5 Sn A gSn A ff=f7f)zThe main Runtime loop. This function won't exit until `stop` is called. Notes ----- Threading: UNSAFE. Must be called on the eventloop thread. zBad Runtime state at start: N) return_whenrrg{Gz?zJ Please report this bug at https://github.com/streamlit/streamlit/issues. )(rrmrHrJrrKrLr]rV set_resultrSis_setrwaitrrTFIRST_COMPLETEDr'cancelrUclearrtlist_active_sessionsrflush_browser_queue _send_messagerridr list_sessionsrrNrW Exception set_exception traceback print_excr(info) rwr done_tasks pending_taskstaskactive_session_infomsg_listrres r4rRuntime._loop_coroutineLsg))+ ^ {{l222 B BC K KK"%A$++#OPP    ) )$ / **1133;;,"D"DD 7>ll#// 0D0D0I0I0KL#// 0I0I0N0N0PQ%,$;$; 671-J!. !.&*@*L [[L$O$OO--335/3/@/@/U/U/W+#6#>#>#R#R#T#+C" $ 2 23F L#*--"222$,0X"-----3:,,++J,@,@,E,E,GH++J,E,E,J,J,LM!( 7 723-) *DKKM*"&<&HA!**1133F!% 1 1 ? ? A !!// 0D0D0G0GH !B OOL00 1    ) )$ /I10$B" $ 1 1 D D$7$?$?$B$B!"" 3. -<     , ,Q /    ! LL   sQ/EP'O(B$P O P7P 8%PP B P)P*AP>& !%6 6   :#C#C C  ) )Q . ) --c2r3cUR5nURRURR5 g)zCallback called by AppSession after the AppSession has enqueued a message. Sets the "needs_send_data" event, which causes our core loop to wake up and flush client message queues. Notes ----- Threading: SAFE. May be called on any thread. N)rrRrrUrrs r4rsRuntime._enqueued_some_messages2))+ 11*2K2K2O2OPr3cJURc [S5eUR$)z`Return our AsyncObjects instance. If the Runtime hasn't been started, this will raise an error. zRuntime hasn't started yet!)rir]r}s r4rRuntime._get_async_objss(    #<= =r3cUR[R:XagURR 5S:XaHUR 5R R5 UR[R5 ggg)z\Set the runtime state to NO_SESSIONS_CONNECTED if the last active session was disconnected. rN) rmrHrLrtnum_active_sessionsrrTrrrKr}s r4r Runtime._on_session_disconnectedse KK<FF F!!5571<  " 1 1 7 7 9 OOL>> ?= Gr3) rirqrnrlrjrkrprrrtrmruro)rrY)rrD)rxr7rr)rrH)rr)rr#)rr!)rr)rr)rzAwaitable[None])rr9rzSessionClient | None)rr9rrr)rr9rrD)NN) rrrzdict[str, str | bool | None]rr;rr;rr9)rr9rr rr)rr9r BaseExceptionrr)rztuple[bool, str])rrHrr)rrrr rr)rrP)&r-r.r/r0r[rF classmethodr`rcrypropertyr~rArr@rrrWrrrrrrrrrrrrrrrrrsrrr2r,r3r4rYrYs $I~$))-W^((''++$$.. # 3!:E*?+/*. ==0=( = ( = =F+/*.   0 (  (   ,(0(014;;$1; ;>$$)V jX38 Q  @r3rY)I __future__rrsysrr dataclassesrrenumrtypingrrr 1streamlit.components.lib.local_component_registryr streamlit.loggerr streamlit.proto.ForwardMsg_pb2r streamlit.runtime.app_sessionr streamlit.runtime.cachingrr:streamlit.runtime.caching.storage.local_disk_cache_storager$streamlit.runtime.media_file_managerr(streamlit.runtime.memory_session_storagerstreamlit.runtime.script_datar+streamlit.runtime.scriptrunner.script_cacher!streamlit.runtime.session_managerrrrrrstreamlit.runtime.staterrstreamlit.runtime.statsr+streamlit.runtime.websocket_session_managerrcollections.abcr2streamlit.components.types.base_component_registryrstreamlit.proto.BackMsg_pb2r !streamlit.runtime.caching.storager!$streamlit.runtime.media_file_storager"'streamlit.runtime.uploaded_file_managerr#r%rFplatformr'r-r(rr*r7rHrPrYr,r3r4r1s# (33T'54BI4C1O)X3EEK#%%$(+||w'>DHH%%F)F $!!!T4":"0Y @Y @r3