U ARd7@s$ddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddl Z ddl m Z mZmZmZmZmZmZmZddlmZddlmZmZddlmZddlmZdd lmZm Z m!Z!dd l"m#Z#m$Z$m%Z%ee&Z'd e j(d d dde j(dd de j(ddddZ)dZ*e#ddddZ+e,ddddZ-ddddZ.dddd Z/e,e e,dd!d"d#Z0e#ddd$d%Z1ddd&d'Z2ddd(d)Z3e,ddd*d+Z4e5dd,d-d.Z6e,ddd/d0Z7ee,efdd1d2d3Z8ee,efdd1d4d5Z9e,dd6d7d8Z:e,e e,e e,ee,efdd9d:d;Z;dS)<N)Path)AnyDictListOptional)configenv_util file_utilnet_utilsecretsurl_utilutilversion)CONFIG_FILENAMES)MIN_GIT_VERSIONGitRepo) get_loggerinvalidate_pages_cache)report_watchdog_availability watch_dir watch_file)Serverserver_address_is_unix_socket server_utilz %(new_version)s See what's new at https://discuss.streamlit.io/c/announcements Enter the following command to upgrade: %(prompt)s %(command)s z(A new version of Streamlit is available.blueTfgbold$rzpip install streamlit --upgrader)Z new_versionpromptcommandi@)serverreturncs^tdfdd}ttj|ttj|tjdkrLttj|nttj|dS)NzSetting up signal handlercs dSN)stop)Z signal_numberZ stack_framer$;/tmp/pip-unpacked-wheel-b9et7o5g/streamlit/web/bootstrap.pysignal_handlerCsz._set_up_signal_handler..signal_handlerwin32) LOGGERdebugsignalSIGTERMSIGINTsysplatformZSIGBREAKSIGQUIT)r$r+r)r(r*_set_up_signal_handler@s   r5)main_script_pathr%cCstjdtj|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)r2pathinsertosdirname)r6r)r)r* _fix_sys_pathOsr;r%cCs:tdr6zddl}|dWntk r4YnXdS)aSet Matplotlib backend to avoid a crash. The default Matplotlib backend crashes Python on OSX when run on a thread that's not the main thread, so here we set a safer backend as a fix. Users can always disable this behavior by setting the config runner.fixMatplotlib = false. This fix is OS-independent. We didn't see a good reason to make this Mac-only. Consistency within Streamlit seemed more important. zrunner.fixMatplotlibrNZAgg)r get_option matplotlibZuse ImportError)r>r)r)r*_fix_matplotlib_crashXs  r@cCsZtjrVtjdkrVzddlm}m}Wntk r8YnXtt |krVt |dS)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) rZ IS_WINDOWSr2 version_infoasynciorDrEr?typeZget_event_loop_policyZset_event_loop_policyrCr)r)r*_fix_tornado_crashusrI)r6argsr%cCsddl}|gt||_dS)ztsys.argv needs to exclude streamlit arguments and parameters and be set to what a user's script may expect. rN)r2listargv)r6rJr2r)r)r* _fix_sys_argvsrMc Cst|jt|jt|jttz tWn0t k rf}zt j d|dW5d}~XYnXdd}t |dS)Nz Failed to load secrets.toml file)exc_infocSs\tdrdStdr$td}n$tdrDtr8dStd}nd}tt|dS)Nserver.headlessbrowser.serverAddressserver.address localhost)rr=is_manually_setrr Z open_browserrget_url)addrr)r)r*maybe_open_browsers     z,_on_server_start..maybe_open_browser)_maybe_print_old_git_warningr6"_maybe_print_static_folder_warning _print_urlis_running_hellor_print_new_version_messager Zload_if_toml_exists Exceptionr-errorrGZget_running_loopZ call_soon)r$exrVr)r)r*_on_server_starts     r_cCstdtjd<dS)z_Sets MAPBOX_API_KEY environment variable needed for PyDeck otherwise it will throw an exceptionz mapbox.tokenZMAPBOX_API_KEYN)rr=r9environr)r)r)r*_fix_pydeck_mapbox_api_warningsracCstrttdSr&)rZshould_show_new_version_noticeclicksechoNEW_VERSION_TEXTr)r)r)r*r[sr[cCshtdrdt|}tj|s8tjd|dddn,t |}|t krdt ddtjddddS) 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.yellowr FzVWARNING: Static folder size is larger than 1GB. Static file serving has been disabled.N) rr=r Zget_app_static_dirr9r7isdirrbrcZget_directory_sizeMAX_APP_STATIC_FOLDER_SIZEZ set_option)r6Zstatic_folder_pathZstatic_folder_sizer)r)r*rXs      rX)rZr%cCs|r d}nd}g}tdr4dttdfg}ntdr\ts\dttdfg}ntrtdtdfg}n|tdrt}|r|dt|ft }|r|d t|fn0d td fg}t}|r|dt|ft d t j d |dddt d |D]\}}t ||qt d |rt dt j dddt j dddt d t dt d t d dS)Nz9Welcome to Streamlit. Check out our demo in your browser.z4You can now view your Streamlit app in your browser.rPURLrQz Unix SocketrOz Network URLz External URLz Local URLrRz %srTrz5 Ready to create your own Python apps super quickly?z Head over to F)nlzhttps://docs.streamlit.ior!z May you create awesome apps!)rrSrrTr=rr Zget_internal_ipappendZget_external_iprbrcr Z print_url)rZZ title_messageZ named_urlsZ internal_ipZ external_ipZurl_nameurlr)r)r*rYsT            rYcCst|}|s|jdk r|jtkrddd|jD}dddtD}tdtjddd d tdtjd |d |ddd tjddd tjddd dS)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.css|]}t|VqdSr&str.0valr)r)r* .sz/_maybe_print_old_git_warning..css|]}t|VqdSr&rnrpr)r)r*rs/sriz Git integration is disabled.reTrz 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.)rZis_validZ git_versionrjoinrbrc)r6repoZgit_version_stringZmin_version_stringr)r)r*rW$s*  rW) flag_optionsr%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|]\}}|dk r|dd|qS)N_rm)replace)rqnamerrr)r)r* Ns z'load_config_options..T)Z force_reparseoptions_from_flagsN)itemsrZget_config_options)rvr{r)r)r*load_config_options?sr}cs0fdd}tD]}tj|rt||qdS)Ncs tdSr&)r}_pathrvr)r*on_config_changedZsz3_install_config_watchers..on_config_changed)rr9r7existsr)rvrfilenamer)rr*_install_config_watchersYs  r)main_script_path_strr%cCs:tdddd}t|}|jd}tt||ddddS)N)rr%cSs tdSr&rr~r)r)r*_on_pages_changedcsz1_install_pages_watcher.._on_pages_changedZpagesz*.pyT)Z glob_patternZallow_nonexistent)rorparentr)rrr6Z pages_dirr)r)r*_install_pages_watcherbs r)r6 command_linerJrvr%cs`t|ttt||tt|t|t||ddfdd }t |dS)zuRun a script in a separate thread and start a server for the app. This starts a blocking asyncio eventloop. Nr<cs.IdHttjIdHdSr&)startr_r5stoppedr)r(r)r* run_serverszrun..run_server) r;r@rIrMrarrrrGrun)r6rrJrvrr)r(r*rqs   r)sZ (        $>