@@ -245,6 +245,9 @@ def start(
245
245
# kernel already exists, in which case the `kernel_id` must not be None
246
246
# enterprise gateway does not provide a good response code
247
247
response = requests .get (urljoin (self .host , f"/api/kernels/{ kernel_id } " ), timeout = 60 )
248
+ if not response .ok :
249
+ error_msg = f"Error starting kernel: { response .status_code } \n { response .content } "
250
+ raise RuntimeError (error_msg )
248
251
else :
249
252
error_msg = f"Error starting kernel: { response .status_code } \n { response .content } "
250
253
raise RuntimeError (error_msg )
@@ -273,17 +276,19 @@ async def astart(
273
276
_body = kernel_request .model_dump ()
274
277
logger .debug ("Starting kernel with payload %s" , _body )
275
278
async with aiohttp .ClientSession (self .host ) as session , session .post ("/api/kernels" , json = _body ) as response :
279
+ resp_text = await response .text ()
276
280
if not response .ok :
277
- if "Kernel already exists:" in response . text :
281
+ if "Kernel already exists:" in resp_text :
278
282
# kernel already exists, in which case the `kernel_id` must not be None
279
283
# enterprise gateway does not provide a good response code
280
284
async with session .get (f"/api/kernels/{ kernel_id } " ) as resp :
281
285
resp_text = await resp .text ()
286
+ if not resp .ok :
287
+ error_msg = f"Error starting kernel: { resp .status } \n { resp .content } "
288
+ raise RuntimeError (error_msg )
282
289
else :
283
290
error_msg = f"Error starting kernel: { response .status } \n { response .content } "
284
291
raise RuntimeError (error_msg )
285
- else :
286
- resp_text = await response .text ()
287
292
kernel = Kernel .model_validate_json (resp_text )
288
293
box = RemotePyBox (kernel , self .get_ws_url (kernel .id ))
289
294
try :
0 commit comments