o dG@s$ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZmZmZmZddlmZeeZdddZGdddZGd d d ejZGd d d eZGd ddeZGdddeZGdddeZ GdddeZ!dS)N)NoAppFoundErrorTestingTimeoutErrorServerCloseErrorDashAppLoadingError)waitappc CsLz t|}||}W|Sty%}z tdtd||d}~ww)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_missingre/var/www/html/visualizacion-main/env/lib/python3.10/site-packages/dash/testing/application_runners.py import_apps   rc@steZdZdZdZddZddZddZed d Z d d Z d dZ ddZ e ddZe ddZe ddZdS)BaseDashRunnerz4Base context manager class for running applications.icCs"d|_d|_||_||_d|_dS)Nr)portstarted keep_open stop_timeout _tmp_app_pathselfrrrrr__init__@s  zBaseDashRunner.__init__cOtNNotImplementedErrorrargskwargsrrrstartGzBaseDashRunner.startcCrrr rrrrstopJr&zBaseDashRunner.stopcCs*zt|WdStjjyYdSw)NFT)requestsget exceptionsRequestException)urlrrr accessibleMs  zBaseDashRunner.accessiblecOs|j|i|Sr)r%r"rrr__call__UszBaseDashRunner.__call__cCs|Srrr'rrr __enter__Xr&zBaseDashRunner.__enter__c Cs^|jr(|js(z td|Wnty'}z td|jd|d}~wwtddS)Nzkilling the app runnerzCannot stop server within z s timeoutz__exit__ complete)rrr infor(rrr)rexc_typeexc_val tracebackcannot_stop_serverrrr__exit__[s    zBaseDashRunner.__exit__cCs d|jS)zThe default server url.zhttp://localhost:)rr'rrrr-fs zBaseDashRunner.urlcCs tjdkS)Nwin32)sysplatformr'rrr is_windowsks zBaseDashRunner.is_windowscCs|jSr)rr'rrr tmp_app_pathoszBaseDashRunner.tmp_app_pathN)__name__ __module__ __qualname____doc__ _next_portrr%r( staticmethodr.r/r0r6propertyr-r:r;rrrrr;s"   rcs$eZdZfddZddZZS) KillerThreadc s&tjdi|ttj|_dS)Nr)superrlist threading_activekeys _old_threads)rr$ __class__rrruszKillerThread.__init__cCstttjD]2}||jvr qtjt|tt }|dkr%t d||dkr7tjt|dt dqdS)NrzInvalid thread id: zStopping thread failure) rErFrGrIctypes pythonapiPyThreadState_SetAsyncExcc_long py_object SystemExit ValueError)r thread_idresrrrkillys  zKillerThread.kill)r<r=r>rrV __classcell__rrrJrrCts rCcs<eZdZdZd fdd ZddZd dd Zd d ZZS)ThreadedRunnerzkRuns a dash application in a thread. This is the default flavor to use in dash integration tests. Fctj||dd|_dSN)rr)rDrthreadrrJrrr zThreadedRunner.__init__cCs|jr ||Std)NzThread is not alive.)r\is_aliver.r)rr-rrrrunning_and_accessibles  z%ThreadedRunner.running_and_accessiblec sfdd}d}jsp|dkrpz4jr$jrnjt|d_dj_jtj fdd|d j_Wn#t yh}zt |d _|d 7}t d WYd }~nd }~wwjsp|dksj_js}td d S)z)Start the app server in threading flavor.c sdjj_djj_}dvr"tj|d<_tjd7_n|d_z jdddi|WdSt yCt dYdSt yU}zt ||d}~ww)NTrrLthreadedServer stoppedr)scriptsconfig serve_locallycsscopyrr@rrunrRr r1 Exceptionr optionserrorrr$rrrrgs     z!ThreadedRunner.start..runrrYtargetTc jSr)r_r-rr'rr z&ThreadedRunner.start..timeoutFrLNzthreaded server failed to start)rr\r^r(rVrCdaemonr%runtilrhr r timesleepr)rr start_timeoutr$rgretrieserrrrlrr%s6        zThreadedRunner.startcCs0|j|jt|jj|jd|_dS)NF)r\rVjoinr until_notr^rrr'rrrr(s   zThreadedRunner.stopFrYrY) r<r=r>r?rr_r%r(rWrrrJrrXs  3rXcs0eZdZd fdd Zd ddZddZZS) MultiProcessRunnerFrYcst||d|_dSrrDrprocrrJrrrs zMultiProcessRunner.__init__c sTdd_fdd}tj|d_jtjfdd|dd _dS) Nrrc svdjj_djj_}z jdddi|WdSty(tdt y:}zt ||d}~ww)NTr`rar) rbrcrdrerfrgrRr r1rhr ri)rr$rrrns     z(MultiProcessRunner.start..targetrmcrorr.r-rr'rrrprqz*MultiProcessRunner.start..rrT) r*r multiprocessProcessrr%rrur)rrrxr$rnrrlrr%s   zMultiProcessRunner.startc Cst|jj}|jddD]}z|Wq tjyYq wz|Wn tjy0Ynwz|dWdStjtjfyGYdSw)NT) recursiverL) psutilrrpidchildrenrV NoSuchProcessrTimeoutExpired)rprocessrrrrr(s"  zMultiProcessRunner.stopr}r~)r<r=r>rr%r(rWrrrJrrs rcs>eZdZdZd fdd Z     dd d Zd d ZZS) ProcessRunnerz}Runs a dash application in a waitress-serve subprocess. This flavor is closer to production environment but slower. FrYcrZr[rrrJrrr r]zProcessRunner.__init__Nrrc s|s |s tddS|_tj|r|n d|d|d|dj d}td|ztj |tj tj d _ t j fd d |d Wnttfy[td d_YdSwd_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)stdoutstderrcrorrrr'rrrp/rqz%ProcessRunner.start..rr'process server has encountered an errorFT)loggingrkrshlexsplitr:r debug subprocessPopenPIPErrruOSErrorrSr rr()rrr raw_commandrrxr#rr'rr%s2     zProcessRunner.startcCs|jrMz1td|jj|j|jr(tj|jr(t d|jt |jt j }|jj|jdWn|yLtd|j|jYnwtddS)Nzproc.terminate with pid %szremoving temporary app path %srrzPsubprocess terminate not success, trying to kill the subprocess in a safe mannerzprocess stop completes!)rr r1r terminater;ospathexistsrshutilrmtreerr communicaterr rV)r_exceptrrrr(9s&    zProcessRunner.stopr})NrNrrY)r<r=r>r?rr%r(rWrrrJrrs 'rc(eZdZd fdd Zd ddZZS) RRunnerFrYcrZr[rrrJrrrQr]zRRunner.__init__Nc stj|rtj|rstj|tdntjjs#dnt dt j _ ztjWntyFtdjYnwtjjd}tdtd|tdtd |t|d d d  }||Wd n1s|wY|}stD] }d|dddvrtjtj|dtdnqrtdfddtD}|D]6}tjjtj|} tj| rtd| t| td|jt|| tdt| qntdtd|tj dtj|dj d} td| z t!j"| t!j#t!j#jr)jnd_$t%j&fd d!|d"Wntt'fyOtd#d$_(Yd Swd%_(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/rL\/get cwd from inspect => %sz3RRunner inferred cwd from the Python call stack: %sc:g|]}|dstjtj|rtj|qS__ startswithrrisdirr{.0_cwdrr  z!RRunner.start..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")'rrrrrcrorrrr'rrrprqzRRunner.start..rrrFT)rrisfilerdirnamer r1r{r:getenvuuiduuid4hexrmkdirr;rr ropenwriteinspectstackreplacerealpathwarninglistdirbasenamerrcopytreerrrrrrrrurSr rrrxrrfpentryassetsassetrnr#rrrrr%Vs                     z RRunner.startr})rNr<r=r>rr%rWrrrJrrPrcr) JuliaRunnerFrYcrZr[rrrJrrrr]zJuliaRunner.__init__Nc stj|rtj|rstj|tdntjjs#dnt dt j _ ztjWntyFtdjYnwtjjd}tdtd|tdtd |t|d d d  }||Wd n1s|wY|}stD] }d|dddvrtjtj|dtdnqrtdfddtD}|D]6}tjjtj|} tj| rtd| t| td|jt|| tdt| qntdtd|tj dtj|j d} td| z t!j"| t!j#t!j#jr(jnd_$t%j&fdd |d!Wntt'fyNtd"d#_(Yd Swd$_(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 apprrrrNrrLrrrz7JuliaRunner inferred cwd from the Python call stack: %scrrrrrrrrrz%JuliaRunner.start..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 --project rzstart Dash.jl process with %srcrorrrr'rrrp rqz#JuliaRunner.start..rrrFTrrrrrr%s                    zJuliaRunner.startr})rNrrrrJrrrr)r)"r8rrvrrrFrrrrrMrr)rrdash.testing.errorsrrrr dash.testingr getLoggerr<r rrThreadrCrXrrrrrrrrs4   9J2Ia