o i@sdZddlZddlmZddlmZmZddlmZddl m Z ddl m Z m Z ddlmZmZdd lmZd d lmZGd d d eeZdS)zgA MultiTerminalManager for use in the notebook webserver - raises HTTPErrors - creates REST API models N) timedelta)utcnow isoformat)NamedTermManager)web)IOLoopPeriodicCallback)Integervalidate)LoggingConfigurable) TERMINAL_CURRENTLY_RUNNING_TOTALcseZdZdZdZdZeddddZdZeedd dZ fd d Z d d Z ddZ ddZ ddZddZd$fdd ZddZddZddZddZd d!Zd"d#ZZS)%TerminalManagerz NFrTzTimeout (in seconds) in which a terminal has been inactive and ready to be culled. Values of 0 or lower disable culling.)confighelpi,z_The interval (in seconds) on which to check for terminals exceeding the inactive timeout value.cstj|i|dSN)super__init__)selfargskwargs __class__\/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/notebook/terminal/terminalmanager.pyr)szTerminalManager.__init__cCs|\}}|||S)Create a new terminal.)new_named_terminal_finish_creaternametermrrrcreate,s  zTerminalManager.createcCs4||jvrtdd|d||}|||S)rizA terminal with name 'z' already exists.) terminalsr HTTPError get_terminalrrrrrcreate_with_name1s   z TerminalManager.create_with_namecCs&t|_||}t||Sr)r last_activityget_terminal_modelr inc_initialize_cullerrrr modelrrrr8s  zTerminalManager._finish_createcCs||}|S)zGet terminal 'name'.r')rrr+rrrgetDs zTerminalManager.getcs&fddjD}tt||S)z$Get a list of all running terminals.csg|]}|qSrr,.0rrrr Ksz(TerminalManager.list..)r"r setlen)rmodelsrr0rlistIs zTerminalManager.listcs.||tj||dIdHtdS)zTerminate terminal 'name'.forceN)_check_terminalr terminater dec)rrr7rrrr9Ss  zTerminalManager.terminatecs4dd|jD}|D] }|j|ddIdHq dS)zTerminate all terminals.cSsg|]}|qSrrr.rrrr1^sz1TerminalManager.terminate_all..Tr6N)r"r9)rtermsr rrr terminate_all\s zTerminalManager.terminate_allcCs(|||j|}|t|jd}|S)zuReturn a JSON-safe dict representing a terminal. For use in representing terminals in the JSON APIs. )rr&)r8r"rr&r*rrrr'bs  z"TerminalManager.get_terminal_modelcCs ||jvrtdd|dS)z9Check a that terminal 'name' exists and raise 404 if not.izTerminal not found: N)r"rr#)rrrrrr8ns zTerminalManager._check_terminalcCs|js=|jdkr=|jdur=t}|jdkr$|jd|j|j|j|_t |j d|j|_|j d|j|j|j d|_dS)zStart culler if 'cull_inactive_timeout' is greater than zero. Regardless of that value, set flag that we've been here. rNzKInvalid value for 'cull_interval' detected (%s) - using default value (%s).izICulling terminals with inactivity > %s seconds at %s second intervals ...T) _initialized_cullercull_inactive_timeout_culler_callbackrcurrent cull_intervallogwarningcull_interval_defaultr_cull_terminalsinfostart)rlooprrrr)ss      z"TerminalManager._initialize_cullerc sz|jd|j|jt|jD]*}z ||IdHWqty:}z|jd|d|WYd}~qd}~wwdS)NzCPolling every %s seconds for terminals inactive for > %s seconds...zPThe following exception was encountered while checking the activity of terminal z: ) rBdebugrAr>r5r"_cull_inactive_terminal Exception exception)rrerrrrEszTerminalManager._cull_terminalscsz|j|}Wn tyYdSw|jd||jt|drMt}||j}|t|jdk}|rOt | }|j d|||j |ddIdHdSdSdS)Nzname=%s, last_activity=%sr&)secondsz6Culling terminal '%s' due to %s seconds of inactivity.Tr6) r"KeyErrorrBrIr&hasattrrrr>int total_secondsrCr9)rrr dt_now dt_inactiveis_time inactivityrrrrJs"    z'TerminalManager._cull_inactive_terminal)F)__name__ __module__ __qualname____doc__r?r=r r>rDrArr!r%rr-r5r9r<r'r8r)rErJ __classcell__rrrrrs0      r)rZwarningsdatetimer notebook._tzrr terminadortornadortornado.iolooprr traitletsr r traitlets.configr prometheus.metricsr rrrrrs