B \@s@dZddlmZddlmZmZmZmZmZGdddeZ 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. )LoggingConfigurable)InstanceFloatDictBoolIntegerc@seZdZdZedZeddddZeddddZ e d dd dZ eddd dZ edZ e d ZedZeZd dZddZddZdddZdddZddZddZdS)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. )Zconfighelpg@z%Kernel heartbeat interval in seconds.zJThe number of consecutive autorestarts before the kernel is presumed dead.zNWhether to choose new random ports when restarting before the kernel is alive.rcCs tggdS)N)restartdead)dict)selfr7lib/python3.7/site-packages/jupyter_client/restarter.py_callbacks_default.sz"KernelRestarter._callbacks_defaultcCs tddS)z Start the polling of the kernel.z!Must be implemented in a subclassN)NotImplementedError)rrrrstart1szKernelRestarter.startcCs tddS)zStop the kernel polling.z!Must be implemented in a subclassN)r)rrrrstop5szKernelRestarter.stopr cCs|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) callbacksappend)rfeventrrr add_callback9s zKernelRestarter.add_callbackcCs.y|j||Wntk r(YnXdS)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)rremove ValueError)rrrrrrremove_callbackDs zKernelRestarter.remove_callbackc CsZxT|j|D]F}y |Wq tk rP}z|jjd||ddWdd}~XYq Xq WdS)z)fire our callbacks for a particular eventz&KernelRestarter: %s callback %r failedT)exc_infoN)r Exceptionlogerror)rrcallbackerrr_fire_callbacksRs  zKernelRestarter._fire_callbackscCs|jr|jd|js|jr2|jd7_nd|_|j|jkrp|jd|dd|_d|_| q|j oz|j }|j d|j|j|rdnd |d |jj d |d d |_n$|j rd|_ |jr|jd d|_dS)NzPolling kernel...zKernelRestarter: restart failedr Frz;KernelRestarter: restarting kernel (%i/%i), %s random portsnewZkeepr T)Znownewportsz-KernelRestarter: restart apparently succeeded)debugrkernel_managerZis_alive _restarting_restart_count restart_limitZwarningr#rrandom_ports_until_alive_initial_startupinfoZrestart_kernel)rr&rrrpollZs2         zKernelRestarter.pollN)r )r )__name__ __module__ __qualname____doc__rr(rr'rZ time_to_deadrr+r,r)r*r-rrrrrrrr#r/rrrrrs* rN) r3Ztraitlets.config.configurablerZ traitletsrrrrrrrrrrs