mirror/notebook
2
0
Fork 0
mirror of https://github.com/jupyter/notebook.git synced 2025-01-12 11:45:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

Correct 'Content-Type' headers

Browse Source
This commit is contained in:
faucct 2021-03-30 08:13:15 +03:00 committed by GitHub
parent b97dda1ade
commit 935d6df839
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
notebook/gateway/managers.py
View File

@ -401,7 +401,9 @@ class GatewayKernelManager(AsyncMappingKernelManager):
json_body = json_encode({'name': kernel_name, 'env': kernel_env})
response = await gateway_request(kernel_url, method='POST', body=json_body)
response = await gateway_request(
kernel_url, method='POST', headers={'Content-Type': 'application/json'}, body=json_body
)
kernel = json_decode(response.body)
kernel_id = kernel['id']
self.log.info("Kernel started: %s" % kernel_id)
@ -489,7 +491,9 @@ class GatewayKernelManager(AsyncMappingKernelManager):
"""
kernel_url = self._get_kernel_endpoint_url(kernel_id) + '/restart'
self.log.debug("Request restart kernel at: %s", kernel_url)
response = await gateway_request(kernel_url, method='POST', body=json_encode({}))
response = await gateway_request(
kernel_url, method='POST', headers={'Content-Type': 'application/json'}, body=json_encode({})
)
self.log.debug("Restart kernel response: %d %s", response.code, response.reason)
async def interrupt_kernel(self, kernel_id, **kwargs):
@ -502,7 +506,9 @@ class GatewayKernelManager(AsyncMappingKernelManager):
"""
kernel_url = self._get_kernel_endpoint_url(kernel_id) + '/interrupt'
self.log.debug("Request interrupt kernel at: %s", kernel_url)
response = await gateway_request(kernel_url, method='POST', body=json_encode({}))
response = await gateway_request(
kernel_url, method='POST', headers={'Content-Type': 'application/json'}, body=json_encode({})
)
self.log.debug("Interrupt kernel response: %d %s", response.code, response.reason)
def shutdown_all(self, now=False):