ث ؟L iQ/مَ$—UddlmZddlZddlZddlZddlZddlmZmZddl m Z mZmZm Z mZmZddlmZddlmZmZddlmZmZmZee«Zded <d Zdd„Zdd„Zdd „Zdd„Z dd„Z!dd„Z"dd„Z#dd„Z$dd„Z%dd„Z&ddœ dd„Z'y)é)عannotationsN)عAnyعFinal)عcli_utilعconfigعenv_utilع file_utilعnet_utilعsecrets)ع get_logger)عreport_watchdog_availabilityع watch_file)عServerعserver_address_is_unix_socketعserver_utilrع_LOGGERi@cَ„‡—tjd«dˆfd„}tjtj|«tjtj|«t jdk(r%tjtj|«ytjtj|«y)NzSetting up signal handlercَ&•—‰j«y©N)عstop)ع signal_numberعstack_frameعservers €ْ]/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/streamlit/web/bootstrap.pyعsignal_handlerz._set_up_signal_handler..signal_handler(sّ€àڈ‰چ َعwin32)rعintrrعreturnعNone) rعdebugعsignalعSIGTERMعSIGINTعsysعplatformعSIGBREAKعSIGQUIT)rrs` rع_set_up_signal_handlerr)%skّ€ـ‡MپMذ-ش.ُô‡MپM”&—.‘. .ش1ـ ‡MپM”&—-‘- ش0ـ ‡|پ|گwزـڈ ‰ ”f—o‘o ~ص6نڈ ‰ ”f—n‘n nص5rcَ~—tjjdtjj |««y)z Add 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%عpathعinsertعosعdirname)عmain_script_paths rع _fix_sys_pathr04s$€ô‡HپH‡OپOگA”r—w‘w—‘ذ'7س8ص9rcَت—tjrD ddlm}m}ttj««|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 r©عWindowsProactorEventLoopPolicyعWindowsSelectorEventLoopPolicyN) rع IS_WINDOWSعasyncior3r4عtypeعget_event_loop_policyعset_event_loop_policyعImportErrorr2s rع_fix_tornado_crashr;=sd€ô ×زً P÷ ô”G×1ر1س3س4ذ8VرVô×-ر-ر.Lس.NصOًWًّôٍ ظً ْs’Aء A"ء!A"cَ2—ddl}|gt|«¢|_y)ztsys.argv needs to exclude streamlit arguments and parameters and be set to what a user's script may expect. rN)r%عlistعargv)r/عargsr%s rع _fix_sys_argvr@]s€َà ذ.¤4¨£:ذ.€C…Hrcَ,—t|j«t|j«t « tj«dd„}tj«j|«y#t$rtjd«YŒHwxYw)Nz Failed to load secrets.toml filecَF—tjd«rytjd«rtjd«}n8tjd«r!t«rytjd«}nd}t j t j|««y)Nْserver.headlessْbrowser.serverAddressْserver.addressع localhost)rع get_optionعis_manually_setrrعopen_browserrعget_url)عaddrs rعmaybe_open_browserz,_on_server_start..maybe_open_browserss{€ـ×رذ.ش/àن×!ر!ذ"9ش:ـ×$ر$ذ%<س=‰Dـ × #ر #ذ$4ش 5ـ,ش.àـ×$ر$ذ%5س6‰DàˆDن×رœk×1ر1°$س7ص8r©rr ) ع"_maybe_print_static_folder_warningr/ع _print_urlعis_running_hellor rعload_if_toml_existsع Exceptionrع exceptionr6عget_running_loopع call_soon)rrLs rع_on_server_startrVfst€ـ& v×'>ر'>ش?ـˆv×&ر&ش'ـ ش"ً >ـ×#ر#ش%َ9ô$×رس×(ر(ذ);ص<ّô+ٍ>ـ×رذ<ض=ً>ْs¶A2ء2BآBcَv—dtjvr'tjd«tjd<yy)ziSets MAPBOX_API_KEY environment variable needed for PyDeck otherwise it will throw an exception. عMAPBOX_API_KEYzmapbox.tokenN)r-عenvironrrG©rrع_fix_pydeck_mapbox_api_warningr[ˆs/€ً œrںz™zر)ـ'-×'8ر'8¸س'HŒڈ ‰ ذ#ز$ً*rcَh—tjd«r‌tj|«}tj j |«stjd|›d‌d¬«ytj|«}|tkDr.tjdd«tjdd¬«yyy) 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.عyellow)عfgFzVWARNING: Static folder size is larger than 1GB. Static file serving has been disabled.N)rrGr عget_app_static_dirr-r+عisdirrعprint_to_cliعget_directory_sizeعMAX_APP_STATIC_FOLDER_SIZEع set_option)r/عstatic_folder_pathعstatic_folder_sizes rrNrN‘s¬€ô×رذ5ش6ـ&×9ر9ذ:JسKذـڈw‰wڈ}‰}ذ/ش0ـ×!ر!ًط(ذ)ً*;ً<ًِ ô"+×!=ر!=ذ>Pس!Qذà!ش$>ز>ـ×!ر!ذ">ہشFـ×%ر%ً=àًِ?ً7rcَ"—|rd}nd}g}tjd«r-dtjtjd««fg}گntjd«r6t«s,dtjtjd««fg}nبt«rdtjd«fg}n¥dtjd«fg}t j«}|r&|jd tj|«f«tjd «rس?ذ@ً ‰ ًœ+×-ر-¨kس:ذ;ً ˆ ô×.ر.س0ˆظط×رک}¬k×.Aر.Aہ+س.NذOشPن×رذ.ش/ـ"×2ر2س4ˆKظط×!ر! >´;×3Fر3Fہ{س3Sذ"TشUن×رک"شـ×رکBک}کoذ.°6ہصEـ×رک"شà#ٍ.‰ ˆگ#ـ×ر 8 *¨Bذ/°E¸fصEـ×رکc¨ض-ً.ô ×رک"شلـ×رذUشVـ×رذ/°Eص:ـ×رذ9ہصEـ×رکbش!ـ×رذ>ش?ـ×رکbش!ـ×رکbص!ًrcَ²—|j«Dڈڈcic]\}}|پ|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. NrZع_ْ.T)ع force_reparseعoptions_from_flags)عitemsعreplacerعget_config_options)عflag_optionsعnameعvalrzs rعload_config_optionsrپهsb€ً(&×+ر+س-÷لˆDگ#طˆ?کs bڑyً ڈ‰گSک#س ر#ًذٌô×ر¨DذEWضXùَs”$Acَ‍‡—dˆfd„}tjd«D].}tjj |«sŒ#t||«Œ0y)Ncَ•—t‰«yr)rپ)ع_pathr~s €rعon_config_changedz3_install_config_watchers..on_config_changedsّ€ـکLص)rzconfig.toml)r„عstrrr )rعget_config_filesr-r+عexistsr)r~r…عfilenames` rع_install_config_watchersrٹs?ّ€ُ*ô×+ر+¨Mس:ٍ4ˆـ ڈ7‰7ڈ>‰>ک(ص#ـگxذ!2ص3ٌ4rF)عstop_immediately_for_testingcَج‡‡‡ —t|«t«t||«t«t |«t||«ٹ d ˆ ˆfd„ٹd ˆfd„}d} t j«d}|r9tjd«t j|«d¬«}|‰ _y tjd«t j|««y #t$rYŒvwxYw)zuRun a script in a separate thread and start a server for the app. This starts a blocking asyncio eventloop. c“َè•K—‰j«ƒd{–—†t‰«t‰«‰r%tj d«‰j«‰jƒd{–—†y7ŒV7Œw)Nz'Stopping server immediately for testing)عstartrVr)rr!rعstopped)rr‹s€€rع run_serverzrun..run_server!s]ّèّ€àڈl‰l‹n×ذـکش ô کvش&ٌ(ـڈM‰MذCشDطڈK‰KŒMًڈn‰n×رً ًّ ْs"ƒA2—A.کAA2ء(A0ء)A2ء0A2c“َ0•K—‰«ƒd{–—†y7ŒwrrZ)rگs€rعmainzrun..main4sّèّ€ظ‹l×زْsƒژڈFTz&Running server in existing event loop.zbootstrap.run_server)rz"Starting new event loop for serverNrM)r0r;r@r[rٹrr6rTعRuntimeErrorrr!عcreate_taskع_bootstrap_taskعrun) r/عis_hellor?r~r‹r’عrunning_in_event_loopعtaskrگrs ` @@rr–r–sاْ€ôذ"ش#ـشـذ" Dش)ـ"ش$ـک\ش*ôذ$ hس /€Fُِ&ً"ذً ن× ر ش"ط $ذٌ ـڈ ‰ ذ>ش?ن×"ر"،4£6ذ0FشGˆً"&ˆصô ڈ ‰ ذ:ش;ـڈ‰‘D“Fصّôٍ لً ْsءCأ C#أ"C#)rrrr )r/r†rr rM)r/r†r?ْ list[str]rr )rPعboolrr )r~ْdict[str, Any]rr )r/r†r—r›r?rڑr~rœr‹r›rr )(ع __future__rr6r-r"r%عtypingrrع streamlitrrrr r rعstreamlit.loggerrعstreamlit.watcherr rعstreamlit.web.serverrrrع__name__rع__annotations__rcr)r0r;r@rVr[rNrOrپrٹr–rZrrْr¥sأًِ#مغ غ غ كçN×Nف'كFكSرSلکHس%€ˆس%ً4ذَ6َ:َPَ@/َ=َDIََ28"َvYَ:4ً*/ٌ AطًAàًAًًAً!ً Aً#'ً Aً ôAr