17
17
from threading import Thread
18
18
from tornado import web
19
19
from tornado .escape import json_encode , json_decode , url_escape , utf8
20
- from tornado .httpclient import HTTPClient , HTTPError
21
20
from traitlets import Instance , DottedObjectName , Type , default
22
21
from typing import Dict
23
22
@@ -43,7 +42,7 @@ def _default_shared_context(self):
43
42
return False # no need to share zmq contexts
44
43
45
44
def __init__ (self , ** kwargs ):
46
- super (GatewayKernelManagers , self ).__init__ (** kwargs )
45
+ super ().__init__ (** kwargs )
47
46
self .kernels_url = url_path_join (GatewayClient .instance ().url , GatewayClient .instance ().kernels_endpoint )
48
47
49
48
def remove_kernel (self , kernel_id ):
@@ -179,7 +178,7 @@ async def cull_kernels(self):
179
178
class GatewayKernelSpecManager (KernelSpecManager ):
180
179
181
180
def __init__ (self , ** kwargs ):
182
- super (GatewayKernelSpecManager , self ).__init__ (** kwargs )
181
+ super ().__init__ (** kwargs )
183
182
base_endpoint = url_path_join (GatewayClient .instance ().url ,
184
183
GatewayClient .instance ().kernelspecs_endpoint )
185
184
@@ -291,7 +290,7 @@ async def kernel_culled(self, kernel_id):
291
290
try :
292
291
km = self .kernel_manager .get_kernel (kernel_id )
293
292
kernel = await km .refresh_model ()
294
- except Exception :
293
+ except Exception : # Let exceptions here reflect culled kernel
295
294
pass
296
295
return kernel is None
297
296
@@ -494,6 +493,7 @@ def send(self, msg: dict) -> None:
494
493
def serialize_datetime (dt ):
495
494
if isinstance (dt , (datetime .date , datetime .datetime )):
496
495
return dt .timestamp ()
496
+ return None
497
497
498
498
def start (self ) -> None :
499
499
pass
@@ -548,7 +548,7 @@ class GatewayKernelClient(AsyncKernelClient):
548
548
_channel_queues = {}
549
549
550
550
def __init__ (self , ** kwargs ):
551
- super (GatewayKernelClient , self ).__init__ (** kwargs )
551
+ super ().__init__ (** kwargs )
552
552
self .kernel_id = kwargs ['kernel_id' ]
553
553
self .channel_socket = None
554
554
self .response_router = None
0 commit comments