5
5
from datetime import datetime
6
6
from tornado import gen
7
7
from tornado .httpclient import HTTPRequest , HTTPResponse , HTTPError
8
- from traitlets . config import Config
8
+ from ipython_genutils . py3compat import str_to_unicode
9
9
from .launchserver import ServerTestBase
10
10
from jupyter_server .gateway .managers import GatewayClient
11
11
@@ -57,7 +57,7 @@ def mock_gateway_request(url, **kwargs):
57
57
58
58
# Fetch all kernelspecs
59
59
if endpoint .endswith ('/api/kernelspecs' ) and method == 'GET' :
60
- response_buf = StringIO (json .dumps (kernelspecs ))
60
+ response_buf = StringIO (str_to_unicode ( json .dumps (kernelspecs ) ))
61
61
response = yield gen .maybe_future (HTTPResponse (request , 200 , buffer = response_buf ))
62
62
raise gen .Return (response )
63
63
@@ -66,7 +66,7 @@ def mock_gateway_request(url, **kwargs):
66
66
requested_kernelspec = endpoint .rpartition ('/' )[2 ]
67
67
kspecs = kernelspecs .get ('kernelspecs' )
68
68
if requested_kernelspec in kspecs :
69
- response_buf = StringIO (json .dumps (kspecs .get (requested_kernelspec )))
69
+ response_buf = StringIO (str_to_unicode ( json .dumps (kspecs .get (requested_kernelspec ) )))
70
70
response = yield gen .maybe_future (HTTPResponse (request , 200 , buffer = response_buf ))
71
71
raise gen .Return (response )
72
72
else :
@@ -81,7 +81,7 @@ def mock_gateway_request(url, **kwargs):
81
81
nt .assert_equal (name , kspec_name ) # Ensure that KERNEL_ env values get propagated
82
82
model = generate_model (name )
83
83
running_kernels [model .get ('id' )] = model # Register model as a running kernel
84
- response_buf = StringIO (json .dumps (model ))
84
+ response_buf = StringIO (str_to_unicode ( json .dumps (model ) ))
85
85
response = yield gen .maybe_future (HTTPResponse (request , 201 , buffer = response_buf ))
86
86
raise gen .Return (response )
87
87
@@ -91,7 +91,7 @@ def mock_gateway_request(url, **kwargs):
91
91
for kernel_id in running_kernels .keys ():
92
92
model = running_kernels .get (kernel_id )
93
93
kernels .append (model )
94
- response_buf = StringIO (json .dumps (kernels ))
94
+ response_buf = StringIO (str_to_unicode ( json .dumps (kernels ) ))
95
95
response = yield gen .maybe_future (HTTPResponse (request , 200 , buffer = response_buf ))
96
96
raise gen .Return (response )
97
97
@@ -107,7 +107,7 @@ def mock_gateway_request(url, **kwargs):
107
107
raise HTTPError (404 , message = 'Kernel does not exist: %s' % requested_kernel_id )
108
108
elif action == 'restart' :
109
109
if requested_kernel_id in running_kernels :
110
- response_buf = StringIO (json .dumps (running_kernels .get (requested_kernel_id )))
110
+ response_buf = StringIO (str_to_unicode ( json .dumps (running_kernels .get (requested_kernel_id ) )))
111
111
response = yield gen .maybe_future (HTTPResponse (request , 204 , buffer = response_buf ))
112
112
raise gen .Return (response )
113
113
else :
@@ -123,10 +123,10 @@ def mock_gateway_request(url, **kwargs):
123
123
raise gen .Return (response )
124
124
125
125
# Fetch existing kernel
126
- if endpoint .rfind ('/api/kernels/' ) >= 0 and method == 'GET' :
127
- requested_kernel_id = endpoint .rpartition ('/' )[2 ]
126
+ if endpoint .rfind ('/api/kernels/' ) >= 0 and method == 'GET' :
127
+ requested_kernel_id = endpoint .rpartition ('/' )[2 ]
128
128
if requested_kernel_id in running_kernels :
129
- response_buf = StringIO (json .dumps (running_kernels .get (requested_kernel_id )))
129
+ response_buf = StringIO (str_to_unicode ( json .dumps (running_kernels .get (requested_kernel_id ) )))
130
130
response = yield gen .maybe_future (HTTPResponse (request , 200 , buffer = response_buf ))
131
131
raise gen .Return (response )
132
132
else :
@@ -351,4 +351,3 @@ def delete_kernel(self, kernel_id):
351
351
response = self .request ('DELETE' , '/api/kernels/' + kernel_id )
352
352
self .assertEqual (response .status_code , 204 )
353
353
self .assertEqual (response .reason , 'No Content' )
354
-
0 commit comments