@@ -72,7 +72,7 @@ async def start_kernel(self, kernel_id=None, path=None, **kwargs):
72
72
kwargs ["cwd" ] = self .cwd_for_path (path )
73
73
74
74
km = self .kernel_manager_factory (parent = self , log = self .log )
75
- await km .start_kernel (** kwargs )
75
+ await km .start_kernel (kernel_id = kernel_id , ** kwargs )
76
76
kernel_id = km .kernel_id
77
77
self ._kernels [kernel_id ] = km
78
78
@@ -368,6 +368,7 @@ async def refresh_model(self, model=None):
368
368
self .log .debug ("Request kernel at: %s" % self .kernel_url )
369
369
try :
370
370
response = await gateway_request (self .kernel_url , method = "GET" )
371
+
371
372
except web .HTTPError as error :
372
373
if error .status_code == 404 :
373
374
self .log .warning ("Kernel not found at: %s" % self .kernel_url )
@@ -434,14 +435,14 @@ async def start_kernel(self, **kwargs):
434
435
response = await gateway_request (self .kernels_url , method = "POST" , body = json_body )
435
436
self .kernel = json_decode (response .body )
436
437
self .kernel_id = self .kernel ["id" ]
438
+ self .kernel_url = url_path_join (self .kernels_url , url_escape (str (self .kernel_id )))
437
439
self .log .info (f"GatewayKernelManager started kernel: { self .kernel_id } , args: { kwargs } " )
438
440
else :
439
441
self .kernel_id = kernel_id
442
+ self .kernel_url = url_path_join (self .kernels_url , url_escape (str (self .kernel_id )))
440
443
self .kernel = await self .refresh_model ()
441
444
self .log .info (f"GatewayKernelManager using existing kernel: { self .kernel_id } " )
442
445
443
- self .kernel_url = url_path_join (self .kernels_url , url_escape (str (self .kernel_id )))
444
-
445
446
async def shutdown_kernel (self , now = False , restart = False ):
446
447
"""Attempts to stop the kernel process cleanly via HTTP."""
447
448
0 commit comments