$g8HxddlZddlZddlZddlZddlZddlZddlZddlZddlZddl 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 ]/var/www/dash_apps/app1/venv/lib/python3.12/site-packages/dash/testing/application_runners.py import_apprsd" %%h/ )* J  7828* =   s A$A  AczeZdZdZdZddZdZdZedZ dZ dZ d Z e d Ze d Ze d Zy )BaseDashRunnerz4Base context manager class for running applications.icf||_||_d|_d|_||_||_d|_y)Nr)schemehostportstarted keep_open stop_timeout _tmp_app_path)selfrrrrs r__init__zBaseDashRunner.__init__@s5    "(!ctNNotImplementedErrorr argskwargss rstartzBaseDashRunner.startI!!r"ctr$r%r s rstopzBaseDashRunner.stopLr+r"cv tj|y#tjj$rYywxYw)NFT)requestsget exceptionsRequestException)urls r accessiblezBaseDashRunner.accessibleOs8  LL ""33  s 88c&|j|i|Sr$)r*r's r__call__zBaseDashRunner.__call__Wstzz4*6**r"c|Sr$r-s r __enter__zBaseDashRunner.__enter__Zs 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)r exc_typeexc_val tracebackcannot_stop_servers r__exit__zBaseDashRunner.__exit__]sn << * 45  '( ' *&01B1B0C9M)* *s%A A=A88A=cR|jd|jd|jS)zThe default server url.z://:)rrrr-s rr4zBaseDashRunner.urlhs'++c$))Adii[99r"c(tjdk(S)Nwin32)sysplatformr-s r is_windowszBaseDashRunner.is_windowsms||w&&r"c|jSr$)rr-s r tmp_app_pathzBaseDashRunner.tmp_app_pathqs!!!r"N)http localhost)__name__ __module__ __qualname____doc__ _next_portr!r*r. staticmethodr5r7r:rApropertyr4rHrJr9r"rrr;sx>J"""+ )::''""r"rc$eZdZfdZdZxZS) KillerThreadc |t|di|ttjj |_y)Nr9)superr!list threading_activekeys _old_threads)r r) __class__s rr!zKillerThread.__init__ws/ "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) rXrYrZr\ctypes pythonapiPyThreadState_SetAsyncExcc_long py_object SystemExit ValueError)r thread_idress rkillzKillerThread.kill{si//0 .runs/3CKK   ,+/CGGNN (kkmGV#.<.G.GG$)))Q.)#FO  111 . ,-   '  s B C$C$CC$rtargetTc:jjSr$)rtr4r-srz&ThreadedRunner.start..sD77Ar"timeoutFr_Nzthreaded server failed to start)rrprsr.rirUdaemonr*runtilrr r timesleepr)r r start_timeoutr)r~retrieserrs`` ` rr*zThreadedRunner.starts (,,7Q; ;;{{++-  ((**#6 %) " !!# A= ${{335 ,,7Q;,{{++- ||%&GH H   %$ 1  1  sCD.. E776E22E7c|jj|jjtj|jj |j d|_y)NF)rprijoinr until_notrsrrr-s rr.zThreadedRunner.stopsG   t{{++T->->? r"Frr) rMrNrOrPr!rtr*r.rjrks@rrmrms : 1Ifr"rmc.eZdZdfd ZddZdZxZS)MultiProcessRunnerc4t|||d|_yr$rWr!procrqs rr!zMultiProcessRunner.__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)NTrwrxr9) ryrzr{r|r}r~rer r<rr )rrrr)s rrz(MultiProcessRunner.start..targets/3CKK   ,+/CGGNN (kkmG 111  ,-   '  s A'B!BB!rc:jjSr$r5r4r-srrz*MultiProcessRunner.start..s4??4884r"rT) r1r multiprocessProcessrr*rrr)r rrr)rs`` ` rr*zMultiProcessRunner.startsRJJvt,  !((7   4mL r"ctj|jj}|j dD]} |j  |j  |jdy#tj $rYOwxYw#tj $rYAwxYw#tjtj f$rYywxYw)NT) recursiver_) psutilrrpidchildrenri NoSuchProcessrTimeoutExpired)r processrs rr.zMultiProcessRunner.stops../$$t$4 D      LLN  LLO''   ##    %%v';';<   s6A6B$B(6B  B B%$B%(#C Crr)rMrNrOr!r*r.rjrks@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|_yrorrqs rr!zProcessRunner.__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: rCz.serverposixstart dash process with %s)stdoutstderrc:jjSr$rr-srrz%ProcessRunner.start..1ttxx8r"r'process server has encountered an errorFT)loggingrrshlexsplitrHr debug subprocessPopenPIPErrrOSErrorrfr rr.)r rr 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 terminaterJospathexistsrshutilrmtreerr communicaterr ri)r _excepts rr.zProcessRunner.stop;s 99 ( 8$))--H ##%$$8I8I)JLL!A4CTCTUMM$"3"34$33 %% --&  -. (  6   %%'  (sC.DAE#"E#r)NrNrr)rMrNrOrPr!r*r.rjrks@rrr s)   %N/r"rc(eZdZdfd ZddZxZS)RRunnerc6t|||d|_yrorrqs rr!zRRunner.__init__Srr"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/r_\/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<rrHgetenvuuiduuid4hexrmkdirrJrr ropenwriteinspectstackreplacerealpathwarninglistdir startswithisdirbasenamerrcopytreerrrrrrrrrfr r rrrrfpentry_assetsassetrr(s ` rr*z RRunner.startXs 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 apprrrrNrr_rrrz7JuliaRunner 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)Nrrks@rrrs Yr"r)r)"rFrrrrrYrrrrr`r r0rrdash.testing.errorsrrrr dash.testingr getLoggerrMr rrThreadrUrmrrrrr9r"rrs        8 $88"8"v<9##<.G^GT//dF/NF/R^m^B_-_r"