g!2HUddlmZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZddlmZddlmZmZddlmZddlmZmZdd lmZmZmZeeZd e d <d Z!dd Z"ddZ#ddZ$ddZ%ddZ&ddZ'ddZ(ddZ)ddZ*d dZ+d dZ,dd d!dZ-y)") annotationsN)AnyFinal)cli_utilconfigenv_util file_utilnet_utilsecrets)CONFIG_FILENAMES)MIN_GIT_VERSIONGitRepo) get_logger)report_watchdog_availability watch_file)Serverserver_address_is_unix_socket server_utilr_LOGGERi@ctjdfd}tjtj|tjtj|t j dk(r%tjtj|ytjtj|y)NzSetting up signal handlerc&jyN)stop) signal_number stack_frameservers L/var/www/openai/venv/lib/python3.12/site-packages/streamlit/web/bootstrap.pysignal_handlerz._set_up_signal_handler..signal_handler*s  win32) rdebugsignalSIGTERMSIGINTsysplatformSIGBREAKSIGQUIT)rrs` r_set_up_signal_handlerr)'sk MM-. MM&...1 MM&--0 ||w foo~6 fnnn5rc~tjjdtjj |y)zAdd the script's folder to the sys path. Python normally does this automatically, but since we exec the script ourselves we need to do it instead. rN)r%pathinsertosdirname)main_script_paths r _fix_sys_pathr06s$ HHOOArww'789rctjrD ddlm}m}t tj |urtj|yyy#t$rYywxYw)a/Set default asyncio policy to be compatible with Tornado 6. Tornado 6 (at least) is not compatible with the default asyncio implementation on Windows. So here we pick the older SelectorEventLoopPolicy when the OS is Windows if the known-incompatible default policy is in use. This has to happen as early as possible to make it a low priority and overridable See: https://github.com/tornadoweb/tornado/issues/2608 FIXME: if/when tornado supports the defaults in asyncio, remove and bump tornado requirement for py38 rWindowsProactorEventLoopPolicyWindowsSelectorEventLoopPolicyN) r IS_WINDOWSasyncior3r4typeget_event_loop_policyset_event_loop_policy ImportErrorr2s r_fix_tornado_crashr;?sd  P G11348VV--.L.NOW    sA A"!A"c4ddl}|gt|z|_y)ztsys.argv needs to exclude streamlit arguments and parameters and be set to what a user's script may expect. rN)r%listargv)r/argsr%s r _fix_sys_argvr@_s !DJ.CHrcft|jt|jt|jt  t jd}tjj|y#t$r!}tjd|Yd}~Ld}~wwxYw)Nz Failed to load secrets.toml file)exc_infocFtjdrytjdrtjd}n8tjdr!trytjd}nd}t j t j|y)Nserver.headlessbrowser.serverAddressserver.address localhost)r get_optionis_manually_setrr open_browserrget_url)addrs rmaybe_open_browserz,_on_server_start..maybe_open_browservs{   . /   ! !"9 :$$%<=D  # #$4 5,.$$%56DDk11$78r)_maybe_print_old_git_warningr/"_maybe_print_static_folder_warning _print_urlis_running_hellorr load_if_toml_exists Exceptionrerrorr6get_running_loop call_soon)rexrMs r_on_server_startrXhs !8!89&v'>'>?v&&' " G##%9$ (();<+ G 82 FFGs B B0B++B0cPtjdtjd<y)z_Sets MAPBOX_API_KEY environment variable needed for PyDeck otherwise it will throw an exceptionz mapbox.tokenMAPBOX_API_KEYN)rrHr-environrr_fix_pydeck_mapbox_api_warningr]s$*#4#4^#DBJJ rchtjdrtj|}tj j |stjd|ddytj|}|tkDr.tjddtjddyyy) z7Prints a warning if the static folder is misconfigured.zserver.enableStaticServingzGWARNING: Static file serving is enabled, but no static folder found at zJ. To disable static file serving, set server.enableStaticServing to false.yellowfgFzVWARNING: Static folder size is larger than 1GB. Static file serving has been disabled.N) rrHr get_app_static_dirr-r+isdirr print_to_cliget_directory_sizeMAX_APP_STATIC_FOLDER_SIZE set_option)r/static_folder_pathstatic_folder_sizes rrOrOs56&99:JKww}}/0  ! !()*;<  "+!=!=>P!Q !$>>!!">F%%=?7rc"|rd}nd}g}tjdr-dtjtjdfg}ntjdr6t s,dtjtjdfg}nt rdtjdfg}ndtjdfg}t j}|r&|jd tj|ftjd r? @ +--k: ; ..0    }k.A.A+.NO P   . /"224K!!>;3F3F{3S"TU " &=0V$G "# #8*B/EfEc-$ "UV/E:9Eb!>?b!b!rct|}|js|j|jtkrdj d|jD}dj dtD}t j dt j ddd t j dt j d |d |dd t j d d t j dd yyyy)zIf our script is running in a Git repo, and we're running a very old Git version, print a warning that Git integration will be unavailable. N.c32K|]}t|ywrstr.0vals r z/_maybe_print_old_git_warning..s%K:J3c#h:Jc32K|]}t|ywrr}rs rrz/_maybe_print_old_git_warning..s%J/3c#h/rrlz Git integration is disabled.r_Trnz Streamlit requires Git z or later, but you have r`z> Git is used by Streamlit Cloud (https://streamlit.io/cloud).z, To enable this feature, please update Git.)ris_valid git_versionr joinrrd)r/repogit_version_stringmin_version_strings rrNrNs # $D MMO    (    . XX%K$:J:J%KK XX%J/%JJb!>8RVWb!'(:';<./q 2  L   :x ! / ) rc|jDcic]\}}||dk7r|jdd|!}}}tjd|ycc}}w)a;Load config options from config.toml files, then overlay the ones set by flag_options. The "streamlit run" command supports passing Streamlit's config options as flags. This function reads through the config options set via flag, massages them, and passes them to get_config_options() so that they overwrite config option defaults and those loaded from config.toml files. Parameters ---------- flag_options : dict[str, Any] A dict of config options where the keys are the CLI flag version of the config option names. Nr\_r{T) force_reparseoptions_from_flags)itemsreplacerget_config_options) flag_optionsnamerrs rload_config_optionsrsd(&++--ID# ?sby S##- DEWXs$Ac~fd}tD].}tjj|s#t ||0y)Nctyr)r)_pathrs ron_config_changedz3_install_config_watchers..on_config_changed s L)r)r r-r+existsr)rrfilenames` r_install_config_watchersrs/*% 77>>( # x!2 3%rF)stop_immediately_for_testingcTt|tt||tt |t ||dfd fd}t jjrt j|yt j|y)zuRun a script in a separate thread and start a server for the app. This starts a blocking asyncio eventloop. cKjd{ttr%tj dj j d{y7V7w)Nz'Stopping server immediately for testing)startrXr)rr!rstopped)rrsr run_serverzrun..run_server=s]lln  v& ( MMC D KKMnn  s"A2A.AA2(A0)A20A2c0Kd{y7wrr\)rsrmainzrun..mainTsls NreturnNone) r0r;r@r]rrr6get_event_loop is_running create_taskrun)r/is_hellor?rrrrrs ` @@rrr(s}"#"D)"$\*$h /F.**,DF#  DFr)rrrr)r/r~rrr)r/r~r? list[str]rr)rQboolrr)rdict[str, Any]rr) r/r~rrr?rrrrrrr). __future__rr6r-r"r%typingrr streamlitrrrr r r streamlit.configr streamlit.git_utilr rstreamlit.loggerrstreamlit.watcherrrstreamlit.web.serverrrr__name__r__annotations__rfr)r0r;r@rXr]rOrPrNrrrr\rrrs# NN-7'FSSH%% 4 6:P@/ =FE 28"v :Y:4*/ 555 5! 5 #' 5 5r