VfGxddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZmZmZmZddlmZej,eZddZGddZGddej6ZGd d eZGd d eZGd deZGddeZ GddeZ!y)N)NoAppFoundErrorTestingTimeoutErrorServerCloseErrorDashAppLoadingError)waitc tj|}||}|S#t$r)}tj dt d||d}~wwxYw)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_moduleappapp_name_missings i/var/www/html/software/conda/envs/catlas/lib/python3.12/site-packages/dash/testing/application_runners.py import_apprsd" %%h/ )* J  7828* =   s A$A  AcxeZdZdZdZdZdZdZedZ dZ dZ d Z e d Ze d Ze d Zy )BaseDashRunnerz4Base context manager class for running applications.icJd|_d|_||_||_d|_y)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 cv tj|y#tjj$rYywxYw)NFT)requestsget exceptionsRequestException)urls r accessiblezBaseDashRunner.accessibleMs8  LL ""33  s 88c&|j|i|Sr")r(r%s r__call__zBaseDashRunner.__call__Ustzz4*6**r c|Sr"r+s r __enter__zBaseDashRunner.__enter__Xs r c|jr2|js& tjd|j tjdy#t $r}t d|jd|d}~wwxYw)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__[sn << * 45  '( ' *&01B1B0C9M)* *s%A A=A88A=c d|jS)zThe default server url.zhttp://localhost:)rr+s rr2zBaseDashRunner.urlfs#499+..r c(tjdk(S)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;sx>J"""+ )//''""r rc$eZdZfdZdZxZS) KillerThreadc |t|di|ttjj |_y)Nr7)superrlist threading_activekeys _old_threads)rr' __class__s rrzKillerThread.__init__us/ "6" !2!2!7!7!9:r cttjD]}||jvrtj j t j|t jt}|dk(rtd||dkDsutj j t j|dtdy)NrzInvalid thread id: zStopping thread failure) rSrTrUrWctypes pythonapiPyThreadState_SetAsyncExcc_long py_object SystemExit ValueError)r thread_idress rkillzKillerThread.killysi//0 .runs/3CKK   ,+/CGGNN (kkmGV#.<.G.GG$)))Q.)#FO  111 . ,-   '  s B C$C$CC$rtargetTc:jjSr")ror2r+srz&ThreadedRunner.start..sD77Ar timeoutFrZNzthreaded server failed to start)rrkrnr,rdrPdaemonr(runtilrzr r timesleepr)rr start_timeoutr'ryretrieserrs`` ` rr(zThreadedRunner.starts (,,7Q; ;;{{++-  ((**#6 %) " !!# A= ${{335 ,,7Q;,{{++- ||%&GH H   %$ 1  1  sCD.. E776E22E7c|jj|jjtj|jj |j d|_y)NF)rkrdjoinr until_notrnrrr+s rr,zThreadedRunner.stopsG   t{{++T->->? r Fr}r}) rHrIrJrKrror(r,rerfs@rrhrhs : 1Ifr rhc.eZdZdfd ZddZdZxZS)MultiProcessRunnerc4t|||d|_yr"rRrprocrls rrzMultiProcessRunner.__init__s L1 r c jdd_fd}tj|_jj t jfd|d_y)NrrcHdjj_djj_j } j dddi|y#t $rtjdt$r}tj||d}~wwxYw)NTrrrsr7) rtrurvrwrxryr`r r:rzr )r{r|rr's rrz(MultiProcessRunner.start..targets/3CKK   ,+/CGGNN (kkmG 111  ,-   '  s A'B!BB!r~c:jjSr"r3r2r+srrz*MultiProcessRunner.start..s4??4884r rT) r/r multiprocessProcessrr(rrr)rrrr'rs`` ` rr(zMultiProcessRunner.startsRJJvt,  !((7   4mL r ctj|jj}|j dD]} |j  |j  |jdy#tj $rYOwxYw#tj $rYAwxYw#tjtj f$rYywxYw)NT) recursiverZ) psutilrrpidchildrenrd NoSuchProcessrTimeoutExpired)rprocessrs rr,zMultiProcessRunner.stops../$$t$4 D      LLN  LLO''   ##    %%v';';<   s6A6B$B(6B  B B%$B%(#C Crr)rHrIrJrr(r,rerfs@rrrs 0r rc<eZdZdZdfd Z ddZdZxZS) ProcessRunnerz}Runs a dash application in a waitress-serve subprocess. This flavor is closer to production environment but slower. c6t|||d|_yrjrrls rrzProcessRunner.__init__  9<H r c  |s|stjdy|_tj|r|n d|d|d|dj }t jd| tj|tjtj _ tjfd | d_y#ttf$r/t j!d d _j%YywxYw)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)stdoutstderrc:jjSr"rr+srrz%ProcessRunner.start../ttxx8r r'process server has encountered an errorFT)loggingr|rshlexsplitrEr debug subprocessPopenPIPErrrOSErrorrar rr,)rrr raw_commandrrr&s` rr(zProcessRunner.startsk MMS   {{ 3D6:,aHXGYY`aoo%    148 "((Z__Z__DI JJ8- P $    F G DL IIK   s*AC;DDc|jr tjd|jj|jj |j rht jj|j r?tjd|j tj|j tj}|jj|jtjdy#$rLtj!d|jj#|jjYfwxYw)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 communicaterr rd)r_excepts rr,zProcessRunner.stop9s 99 ( 8$))--H ##%$$8I8I)JLL!A4CTCTUMM$"3"34$33 %% --&  -. (  6   %%'  (sC.DAE#"E#r)NrNrr})rHrIrJrKrr(r,rerfs@rrrs)   %N/r rc(eZdZdfd ZddZxZS)RRunnerc6t|||d|_yrjrrls rrzRRunner.__init__Qrr c v tjj|rYtjj|r:|stjj |}t j d|njtjjjsdntjdtjj_ tjjtjjjd}t j dt j d|t j%dt j%d |t'|d d 5}|j)|d d d |}|st+j,D]p}d|dj/ddvstjj tjj1|d}t j3d|n|rt j d|tj4|Dcgc]p}|j7ds]tjj9tjj||r tjj||r}}|D]} tjjjtjj;| } tjj| r+t j%d| t=j>| t j%d| jt=j@| | t j%dtj4| nt j3dt j d|tCjDdtjj1|dj } t j%d|  tGjH| tFjJtFjJjr jn|_&tOjPfd| d#_*y #t $r$t j#djYwxYw#1swY^xYwcc}w#t tRf$rt j#d!d"_*Yy wxYw)$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: %s__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")'rrrrcwdc:jjSr"rr+srrzRRunner.start..rr rrFT+rrisfilerdirnamer r:rrEgetenvuuiduuid4hexrmkdirrGrr ropenwriteinspectstackreplacerealpathwarninglistdir startswithisdirbasenamerrcopytreerrrrrrrrrar rrrrrfpentry_assetsassetrr&s ` rr(z RRunner.startVs 77>># 277>>##6ggooc* DcJ"$"oo299V3DdjjlFVFV"D  W**+77<< 1 17;D KK> ? KKEt L LL3 4 LLs #dC'2 b  C$]]_E'uQx/?/?c/JJ ggoobgg.>.>uQx.HI'CSI   QSVW  ZZ_<<-"''-- SRS@T2UGGLLa( $GEWW\\$*;*;RWW=M=Me=TUFww~~f- %@&I f-LL!3UD| t j%d| jt=j@| | t j%dtj4| nt j3dt j d|tCjDdtjj1|j } t j%d|  tGjH| tFjJtFjJjr jn|_&tOjPfd|d"_*y #t $r$t j#djYwxYw#1swY]xYwcc}w#t tRf$rt j#d d!_*Yy wxYw)#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: %srrrrzJuliaRunner 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 --project rzstart Dash.jl process with %src:jjSr"rr+srrz#JuliaRunner.start.. rr rrFTrrs ` rr(zJuliaRunner.starts 77>># 277>>##6ggooc* H#N"$"oo299V3DdjjlFVFV"D  W**+77<< 1 18.>uQx.HI'CSI   Ms ZZ_<<-"''-- SRS@T2UGGLLa( $GEWW\\$*;*;RWW=M=Me=TUFww~~f- %@&I f-LL!3UDQ   4d; "((!!)-):):D%% DI JJ8- P S W  !BDDUDUV W  &P$    F G DL  s8S S7A5TA,T )S43S47T +T76T7r)Nrrfs@rrrs Yr r)r)"rCrrrrrTrrrrr[r r.rrdash.testing.errorsrrrr dash.testingr getLoggerrHr rrThreadrPrhrrrrr7r rrs        8 $86"6"r<9##<.G^GT//dF/NF/R^m^B_-_r