o h2@s@UddlmZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZddlmZddlmZmZddlmZddlmZmZdd lmZmZmZeeZd e d <d Z!d5ddZ"d6ddZ#d7ddZ$d8ddZ%d5ddZ&d7dd Z'd6d!d"Z(d9d%d&Z)d6d'd(Z*d:d+d,Z+d:d-d.Z,d/d0d;d3d4Z-dS)<) 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@serverrreturnNonecs`tdfdd}ttj|ttj|tjdkr'ttj|dSttj|dS)NzSetting up signal handlercs dSN)stop) signal_number stack_framerK/var/www/vscode/kcb/lib/python3.10/site-packages/streamlit/web/bootstrap.pysignal_handler*s z._set_up_signal_handler..signal_handlerwin32) rdebugsignalSIGTERMSIGINTsysplatformSIGBREAKSIGQUIT)rrrrr_set_up_signal_handler's   r)main_script_pathstrcCstjdtj|dS)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)r*rrr _fix_sys_path6sr0cCsXtjr(z ddlm}m}Wn tyYdSwtt|ur*t|dSdSdS)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_WINDOWSasyncior2r3 ImportErrortypeget_event_loop_policyset_event_loop_policyr1rrr_fix_tornado_crash?s  r:args list[str]cCsddl}|gt||_dS)ztsys.argv needs to exclude streamlit arguments and parameters and be set to what a user's script may expect. rN)r%listargv)r*r;r%rrr _fix_sys_argv_sr?c Cs~t|jt|jt|jtztWnty1}z t j d|dWYd}~nd}~wwdd}t |dS)Nz Failed to load secrets.toml file)exc_infocSs\tdrdStdrtd}ntdr"trdStd}nd}tt|dS)Nserver.headlessbrowser.serverAddressserver.address localhost)r get_optionis_manually_setrr open_browserrget_url)addrrrrmaybe_open_browservs     z,_on_server_start..maybe_open_browser)_maybe_print_old_git_warningr*"_maybe_print_static_folder_warning _print_urlis_running_hellorr load_if_toml_exists Exceptionrerrorr5get_running_loop call_soon)rexrJrrr_on_server_starths    rUcCstdtjd<dS)ziSets MAPBOX_API_KEY environment variable needed for PyDeck otherwise it will throw an exception. z mapbox.tokenMAPBOX_API_KEYN)rrEr.environrrrr_fix_pydeck_mapbox_api_warningsrXcCsrtdr5t|}tj|stjd|ddddSt |}|t kr7t ddtjddddSdSdS) 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) rrErget_app_static_dirr.r,isdirr print_to_cliget_directory_sizeMAX_APP_STATIC_FOLDER_SIZE set_option)r*static_folder_pathstatic_folder_sizerrrrLs$       rLrNboolcCs|rd}nd}g}tdrdttdfg}nMtdr.ts.dttdfg}n9tr:dtdfg}n-dtdfg}t}|rR|d t|ftd rgt }|rg|d t|ft d t j d |dddt d |D]\}}t j d|ddddt j |ddq}t d |rt dt j dddt j dddt d t dt d t d dSdS)Nz9Welcome to Streamlit. Check out our demo in your browser.z4You can now view your Streamlit app in your browser.rBURLrCz Unix Socketz Local URLrDz Network URLrAz External URLz %sblueTr[boldz z: F)nlr[)riz5 Ready to create your own Python apps super quickly?z Head over to )rjzhttps://docs.streamlit.ioz May you create awesome apps!) rrFrrHrErr get_internal_ipappendget_external_iprr^)rN title_message named_urls internal_ip external_ipurl_nameurlrrrrMsR            rMcCst|}|sW|jdurY|jtkr[ddd|jD}dddtD}tdtjddd d tdtjd |d |ddd tjddd tjddd dSdSdSdS)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.cs|]}t|VqdSrr+.0valrrr z/_maybe_print_old_git_warning..csrurrvrwrrrrzr{rfz Git integration is disabled.rYTrhz Streamlit requires Git z or later, but you have rZz> Git is used by Streamlit Cloud (https://streamlit.io/cloud).z, To enable this feature, please update Git.)r is_valid git_versionr joinrr^)r*repogit_version_stringmin_version_stringrrrrKs4     rK flag_optionsdict[str, Any]cCs$dd|D}tjd|ddS)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. cSs.i|]\}}|dur|dkr|dd|qS)Nr_rt)replace)rxnameryrrr s  z'load_config_options..T) force_reparseoptions_from_flagsN)itemsrget_config_options)rrrrrload_config_optionssrcs0fdd}tD] }tj|rt||qdS)Ncs tdSr)r)_pathrrron_config_changed"s z3_install_config_watchers..on_config_changed)r r.r,existsr)rrfilenamerrr_install_config_watchers!s   rF)stop_immediately_for_testingis_hellorcst|tt||tt|t||dfdd fdd}ztr6t |WdSt |WdSt yNt |YdSw) zuRun a script in a separate thread and start a server for the app. This starts a blocking asyncio eventloop. rrcsFIdHttrtdjIdHdS)Nz'Stopping server immediately for testing)startrUr)rr!rstoppedr)rrrr run_server?s zrun..run_servercsIdHdSrrr)rrrmainVszrun..mainNrr) r0r:r?rXrrr5rR is_running create_taskrun RuntimeError)r*rr;rrrr)rrrrr*s      r)rrrr)r*r+rrr)r*r+r;r<rr)rNrdrr)rrrr) r*r+rrdr;r<rrrrdrr). __future__rr5r.r"r%typingrr streamlitrrrrr r streamlit.configr streamlit.git_utilr r streamlit.loggerrstreamlit.watcherrrstreamlit.web.serverrrr__name__r__annotations__r`r)r0r:r?rUrXrLrMrKrrrrrrrs6      #   ;