MfGddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZmZmZmZddlmZejeZddZGddZGdd ejZGd d eZGd d eZGddeZGddeZ GddeZ!dS)N)NoAppFoundErrorTestingTimeoutErrorServerCloseErrorDashAppLoadingError)waitappc tj|}||}n?#t$r2}tdt d||d}~wwxYw|S)a Import a dash application from a module. The import path is in dot notation to the module. The variable named app will be returned. :Example: >>> app = import_app("my_app.app") Will import the application in module `app` of the package `my_app`. :param app_file: Path to the app (dot-separated). :type app_file: str :param application_name: The name of the dash application instance. :raise: dash_tests.errors.NoAppFoundError :return: App from module. :rtype: dash.Dash zthe app name cannot be foundz$No dash `app` instance was found in N)runpy run_moduleKeyErrorlogger exceptionr)app_fileapplication_name app_modulerapp_name_missings _/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/dash/testing/application_runners.py import_apprs" %h// )*    7888 =8 = =    Js A-AAceZdZdZdZdZdZdZedZ dZ dZ d Z e d Ze d Ze d Zd S)BaseDashRunnerz4Base context manager class for running applications.icLd|_d|_||_||_d|_dS)Nr)portstarted keep_open stop_timeout _tmp_app_path)selfrrs r__init__zBaseDashRunner.__init__@s-  "(!ctNNotImplementedErrorrargskwargss rstartzBaseDashRunner.startG!!r ctr"r#rs rstopzBaseDashRunner.stopJr)r ch tj|n#tjj$rYdSwxYwdS)NFT)requestsget exceptionsRequestException)urls r accessiblezBaseDashRunner.accessibleMsG  L    "3   55 ts //c|j|i|Sr")r(r%s r__call__zBaseDashRunner.__call__Ustz4*6***r c|Sr"r+s r __enter__zBaseDashRunner.__enter__Xs r c |jrb|js[ td|n+#t $r}t d|jd|d}~wwxYwtddS)Nzkilling the app runnerzCannot stop server within z s timeoutz__exit__ complete)rrr infor,rrr)rexc_typeexc_val tracebackcannot_stop_servers r__exit__zBaseDashRunner.__exit__[s < * * * 4555 & * * *&M1BMMM)* *  '(((((s.? A' A""A'cd|jS)zThe default server url.zhttp://localhost:)rr+s rr2zBaseDashRunner.urlfs/49...r c"tjdkS)Nwin32)sysplatformr+s r is_windowszBaseDashRunner.is_windowsks|w&&r c|jSr")rr+s r tmp_app_pathzBaseDashRunner.tmp_app_pathos !!r N)__name__ __module__ __qualname____doc__ _next_portrr(r, staticmethodr3r5r8r?propertyr2rErGr7r rrr;s>>J"""""""""\+++ ) ) )//X/''X'""X"""r rc$eZdZfdZdZxZS) KillerThreadc tjdi|ttj|_dS)Nr7)superrlist threading_activekeys _old_threads)rr' __class__s rrzKillerThread.__init__usE""6""" !2!7!7!9!9::r cttjD]}||jvr tjt j|t jt}|dkrtd||dkrAtjt j|dtddS)NrzInvalid thread id: zStopping thread failure) rSrTrUrWctypes pythonapiPyThreadState_SetAsyncExcc_long py_object SystemExit ValueError)r thread_idress rkillzKillerThread.killysi/00 < .runs/3CK  ,+/CGN (kkmmGV##.<.GG$)))Q.)))#FO  11111111 . . . ,------     '''  s6B$C. C7CCrritargetTc8jSr")rpr2r+srz&ThreadedRunner.start..sD77AAr timeoutFrZNzthreaded server failed to start)rrlror,rdrPdaemonr(runtilr{r rtimesleepr)rr start_timeoutr'rzretrieserrs`` ` rr(zThreadedRunner.starts       (, 7Q;; ;+{++--+  ((****#666 %) " !!### AAAA= ${3355      %%%$ 1  1  !, 7Q;;,{++-- | I%&GHH H I IsB?C D+':D&&D+c|j|jtj|jj|jd|_dS)NF)rlrdjoinr until_notrorrr+s rr,zThreadedRunner.stopsO   t{+T->??? r Friri) rHrIrJrKrrpr(r,rerfs@rrhrhs~ ::: 1I1I1I1Ifr rhc.eZdZdfd ZddZdZxZS)MultiProcessRunnerFricZt||d|_dSr"rRrprocrms rrzMultiProcessRunner.__init__s( L111 r c dd_fd}tj|_jt jfd|d_dS)Nrrc8djj_djj_} jdddi|dS#t $rtdt$r!}t ||d}~wwxYw)NTrsrtr7) rurvrwrxryrzr`r r:r{r)r|r}rr's rrz(MultiProcessRunner.start..targets/3CK  ,+/CGN (kkmmG 11111111    ,---     '''  sA .B8BBr~c8jSr"r3r2r+srrz*MultiProcessRunner.start..s4??4844r rT) r/r multiprocessProcessrr(rrr)rrrr'rs`` ` rr(zMultiProcessRunner.startsJJvt,,       !(777   4444mLLLL r ctj|jj}|dD],} |#tj$rY)wxYw |n#tj$rYnwxYw |ddS#tjtjf$rYdSwxYw)NT) recursiverZ) psutilrrpidchildrenrd NoSuchProcessrTimeoutExpired)rprocessrs rr,zMultiProcessRunner.stops.//$$t$44  D  '      LLNNNN#    D   LLOOOOO%v';<    DD s5A  AA#A88B  B B%%CCrr)rHrIrJrr(r,rerfs@rrrs` 0r rc<eZdZdZd fd Z d dZd ZxZS) ProcessRunnerz}Runs a dash application in a waitress-serve subprocess. This flavor is closer to production environment but slower. Fric\t||d|_dSrkrrms rrzProcessRunner.__init__ + 9<HHH r Nrrc |s|stjddS|_tj|r|n d|d|d|dj }t d| tj |tj tj _ tj fd | nM#ttf$r9t d d _YdSwxYwd_dS)z7Start the server with waitress-serve in process flavor.zAthe process runner needs to start with at least one valid commandNz waitress-serve --listen=0.0.0.0: :z.serverposixstart dash process with %s)stdoutstderrc8jSr"rr+srrz%ProcessRunner.start../ttx88r r'process server has encountered an errorFT)loggingr}rshlexsplitrEr debug subprocessPopenPIPErrrOSErrorrarrr,)rrr raw_commandrrr&s` rr(zProcessRunner.startsD k  MS    F { bKKaDaa:aaHXaaao%      14888 "(Z_Z_DI J8888- P P P P P$      F G G G DL IIKKK FF    s)A B33AC=<C=c|jr' td|jj|j|jr]t j|jr9t d|jtj |jtj }|j|jnW#|$rOtd|j|jYnwxYwtddS)Nzproc.terminate with pid %szremoving temporary app path %srzPsubprocess terminate not success, trying to kill the subprocess in a safe mannerzprocess stop completes!)rr r:r terminaterGospathexistsrshutilrmtreerr communicaterrrd)r_excepts rr,zProcessRunner.stop9sA 9 ( ( 8$)-HHH ##%%%$58I)J)J5LL!A4CTUUUM$"3444$3 %% -& ( ( (  6     %%'''''  (  -.....sCCAD-,D-r)NrNrri)rHrIrJrKrr(r,rerfs@rrrs|   %%%%N///////r rc(eZdZdfd ZddZxZS) RRunnerFric\t||d|_dSrkrrms rrzRRunner.__init__Qrr Nc tj|r]tj|r>s:tj|t dnWtjjsdntj dtj j _ tjjn0#t $r#t djYnwxYwtjjd}t dt d|t dt d |t'|d d 5}||d d d n #1swxYwY|}st+jD]}d|dddvr_tjtj|dt dnr4t dfdtjD}|D]}tjjtj|} tj| r/t d| t9j| t d|jt9j|| t dtj| nt dt d|t?j dtj|dj } t d|  tCj"| tBj#tBj#jrjn_$tKj&fd| n9#t tNf$r%t d!d"_(Yd SwxYwd#_(d S)$z-Start the server with subprocess and Rscript.z&RRunner inferred cwd from app path: %s/tmpTEMPcannot make temporary folder %szapp.Rz$RRunner start => app is R code chunkz+make a temporary R file for execution => %szcontent of the dashR app%swutf-8encodingN/dash/testing/rZ\/get cwd from inspect => %sz3RRunner inferred cwd from the Python call stack: %scg|]t}|dtjtj|Ttj|uS__ startswithrrisdirr.0_cwds r z!RRunner.start..t<<--35'-- SRS@T@T2U2UGLLa((r delete existing target %scopying %s => %scopied with %szRRunner found no cwd in the Python call stack. You may wish to specify an explicit working directory using something like: dashr.run_server(app, cwd=os.path.dirname(__file__))z Run dashR app with Rscript => %szRscript -e 'source("z")'rrrrrc8jSr"rr+srrzRRunner.start..rr rrFT)rrisfilerdirnamer r:rrEgetenvuuiduuid4hexrmkdirrGrrropenwriteinspectstackreplacerealpathwarninglistdirbasenamerrcopytreerrrrrrrrrar rrrrrfpentryassetsassetrr&s ` ` rr(z RRunner.startVs 7>>#  < 27>>##6#6<  Kgooc** DcJJJ"$"oD29V3D3DdjllFV""D  W*++++ W W W  !BDDUVVVVV W7<< 17;;D KK> ? ? ? KKEt L L L LL3 4 4 4 LLs # # #dC'222 b                C $]__E'uQx/?/?c/J/JJJ goobg.>.>uQx.H.HII'CSIIIK  QSVWWWZ__ $GGEW\\$*;RW=M=Me=T=TUUFw~~f--. %@&III f---LL!3UDs:tj|t dnWtjjsdntj dtj j _ tjjn0#t $r#t djYnwxYwtjjd}t dt d|t dt d |t'|d d 5}||d d d n #1swxYwY|}st+jD]}d|dddvr_tjtj|dt dnr4t dfdtjD}|D]}tjjtj|} tj| r/t d| t9j| t d|jt9j|| t dtj| nt dt d|t?j dtj|j } t d|  tCj"| tBj#tBj#jrjn_$tKj&fd|n9#t tNf$r%t d d!_(Yd SwxYwd"_(d S)#z+Start the server with subprocess and julia.z*JuliaRunner inferred cwd from app path: %srrrzapp.jlz,JuliaRunner start => app is Julia code chunkz/make a temporary Julia file for execution => %szcontent of the Dash.jl apprrrrNrrZrrrz7JuliaRunner inferred cwd from the Python call stack: %scg|]t}|dtjtj|Ttj|uSrrrs rrz%JuliaRunner.start..rr rrrzJuliaRunner found no cwd in the Python call stack. You may wish to specify an explicit working directory using something like: dashjl.run_server(app, cwd=os.path.dirname(__file__))z Run Dash.jl app with julia => %szjulia rzstart Dash.jl process with %src8jSr"rr+srrz#JuliaRunner.start..rr rrFTrrs ` ` rr(zJuliaRunner.starts 7>>#  > 27>>##6#6>  Ogooc** H#NNN"$"oD29V3D3DdjllFV""D  W*++++ W W W  !BDDUVVVVV W7<< 18<.>uQx.H.HII'CSIIIK  Ms Z__ $GGEW\\$*;RW=M=Me=T=TUUFw~~f--. %@&III f---LL!3UDr se       8 $ $86"6"6"6"6"6"6"6"r<<<<<9#<<<.GGGGG^GGGT////////dF/F/F/F/F/NF/F/F/R^^^^^m^^^B]]]]]-]]]]]r