o i@sLdZddlZddlmZmZmZmZmZmZddl m Z Gddde Z dS)zA basic kernel monitor with autorestarting. This watches a kernel's state using KernelManager.is_alive and auto restarts the kernel if it dies. It is an incomplete base class, and must be subclassed. N)BoolDictFloatInstanceIntegerdefault)LoggingConfigurablec@seZdZdZedZeddddZeddddZ ed dd dZ e d dd dZ eddd dZ edZe dZedZeZedddZeZddZddZddZd"ddZd"ddZddZdd Zd!S)#KernelRestarterz!Monitor and autorestart a kernel.zjupyter_client.KernelManagerFTzWhether to include every poll event in debugging output. Has to be set explicitly, because there will be *a lot* of output. )confighelpg@z%Kernel heartbeat interval in seconds.g$@zOThe time in seconds to consider the kernel to have completed a stable start up.zJThe number of consecutive autorestarts before the kernel is presumed dead.zNWhether to choose new random ports when restarting before the kernel is alive.r _last_deadcCstS)N)timeselfrS/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/jupyter_client/restarter.py_default_last_dead6sz"KernelRestarter._default_last_deadcCs ggdS)N)restartdeadrrrrr_callbacks_default<s z"KernelRestarter._callbacks_defaultcC d}t|)z Start the polling of the kernel.!Must be implemented in a subclassNotImplementedErrorrmsgrrrstart?zKernelRestarter.startcCr)zStop the kernel polling.rrrrrrstopDrzKernelRestarter.stoprcCs|j||dS)zregister a callback to fire on a particular event Possible values for event: 'restart' (default): kernel has died, and will be restarted. 'dead': restart has failed, kernel will be left dead. N) callbacksappendrfeventrrr add_callbackIs zKernelRestarter.add_callbackcCs,z |j||WdStyYdSw)zunregister a callback to fire on a particular event Possible values for event: 'restart' (default): kernel has died, and will be restarted. 'dead': restart has failed, kernel will be left dead. N)r remove ValueErrorr"rrrremove_callbackTs   zKernelRestarter.remove_callbackc CsD|j|D]}z|Wqty|jjd||ddYqwdS)z)fire our callbacks for a particular eventz&KernelRestarter: %s callback %r failedT)exc_infoN)r Exceptionlogerror)rr$callbackrrr_fire_callbacksbs   zKernelRestarter._fire_callbackscCsP|jr |jd|jjr|jddSt}|jss||_|jr,|jd7_nd|_|j|j krL|j d| dd|_d|_| dS|j oQ|j}|jd|j|j |r^d nd | d |jjd |d d |_dS|j}|jjr|jjj|d}|jr||j|krd|_|jr||j|kr|jdd|_dSdSdS)NzPolling kernel...zKernel shutdown in progress...zKernelRestarter: restart failedrFrz;KernelRestarter: restarting kernel (%i/%i), %s random portsnewkeeprT)nownewports) recommendedz-KernelRestarter: restart apparently succeeded)debugr+kernel_manager shutting_downris_aliver _restarting_restart_count restart_limitwarningr.rrandom_ports_until_alive_initial_startupinforestart_kernelstable_start_time provisionerget_stable_start_time)rr2r3rArrrpollosL              zKernelRestarter.pollN)r)__name__ __module__ __qualname____doc__rr6rr5r time_to_deadrArr;r=r9r:r>r rrrr rrrr%r(r.rDrrrrr sL     r ) rHr traitletsrrrrrrtraitlets.config.configurablerr rrrrs