Jun 8, 2018 · Jun 6, 2018 · Jun 6, 2018 · Jun 6, 2018
diff --git a/notebook/services/kernels/handlers.py b/notebook/services/kernels/handlers.py

 @property
 defkernel_info_timeout(self):
 returnself.settings.get('kernel_info_timeout',10)
 km_default=self.kernel_manager.kernel_info_timeout
 returnself.settings.get('kernel_info_timeout',km_default)

 @property
 defiopub_msg_rate_limit(self):
diff --git a/notebook/services/kernels/kernelmanager.py b/notebook/services/kernels/kernelmanager.py
 from jupyter_client.session import Session
 from jupyter_client.multikernelmanager import MultiKernelManager
 from traitlets import (Any, Bool, Dict, List, Unicode, TraitError, Integer,
       Instance, default, validate
 Float,Instance, default, validate
 )

 from notebook.utils import to_os_path, exists
        no frontends are connected.
        """
    )

    kernel_info_timeout = Float(60, config=True,
        help="""Timeout for giving up on a kernel (in seconds).

        On starting and restarting kernels, we check whether the
        kernel is running and responsive by sending kernel_info_requests.
        This sets the timeout in seconds for how long the kernel can take
        before being presumed dead.
        This affects the MappingKernelManager (which handles kernel restarts)
        and the ZMQChannelsHandler (which handles the startup).
        """
    )

    _kernel_buffers = Any()
    @default('_kernel_buffers')
        kernel.session.send(channel, "kernel_info_request")
        channel.on_recv(on_reply)
        loop = IOLoop.current()
        timeout = loop.add_timeout(loop.time() +30, on_timeout)
        timeout = loop.add_timeout(loop.time() +self.kernel_info_timeout, on_timeout)
        return future

    def notify_connect(self, kernel_id):
                self.log.warning("Culling '%s' kernel '%s' (%s) with %d connections due to %s seconds of inactivity.",
                                 kernel.execution_state, kernel.kernel_name, kernel_id, connections, idle_duration)
                self.shutdown_kernel(kernel_id)
Original file line number	Diff line number	Diff line change
Expand Up		@@ -104,7 +104,8 @@ class ZMQChannelsHandler(AuthenticatedZMQStreamHandler):

		@property
		defkernel_info_timeout(self):
		returnself.settings.get('kernel_info_timeout',10)
		km_default=self.kernel_manager.kernel_info_timeout
		returnself.settings.get('kernel_info_timeout',km_default)

		@property
		defiopub_msg_rate_limit(self):
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -19,7 +19,7 @@
		from jupyter_client.session import Session
		from jupyter_client.multikernelmanager import MultiKernelManager
		from traitlets import (Any, Bool, Dict, List, Unicode, TraitError, Integer,
		Instance, default, validate
		Float,Instance, default, validate
		)

		from notebook.utils import to_os_path, exists
Expand DownExpand Up		@@ -93,6 +93,18 @@ def _update_root_dir(self, proposal):
		no frontends are connected.
		"""
		)

		kernel_info_timeout = Float(60, config=True,
Copy link Member rgbkrkJun 6, 2018 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. Excellent!
		help="""Timeout for giving up on a kernel (in seconds).

		On starting and restarting kernels, we check whether the
		kernel is running and responsive by sending kernel_info_requests.
		This sets the timeout in seconds for how long the kernel can take
		before being presumed dead.
		This affects the MappingKernelManager (which handles kernel restarts)
		and the ZMQChannelsHandler (which handles the startup).
		"""
		)

		_kernel_buffers = Any()
		@default('_kernel_buffers')
Expand DownExpand Up		@@ -305,7 +317,7 @@ def on_restart_failed():
		kernel.session.send(channel, "kernel_info_request")
		channel.on_recv(on_reply)
		loop = IOLoop.current()
		timeout = loop.add_timeout(loop.time() +30, on_timeout)
		timeout = loop.add_timeout(loop.time() +self.kernel_info_timeout, on_timeout)
		return future

		def notify_connect(self, kernel_id):
Expand DownExpand Up		@@ -434,4 +446,3 @@ def cull_kernel_if_idle(self, kernel_id):
		self.log.warning("Culling '%s' kernel '%s' (%s) with %d connections due to %s seconds of inactivity.",
		kernel.execution_state, kernel.kernel_name, kernel_id, connections, idle_duration)
		self.shutdown_kernel(kernel_id)