Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix identation

Browse source
This commit is contained in:
marc hurabielle 2019-09-11 13:08:19 +09:00
parent fe20923cf3
commit 30ef7f7cba
1 changed files with 13 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
python/src/main/resources/grpc/python/ipython_server.py
View file

@ -61,13 +61,10 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
print("******************* CONTENT ******************")
print(str(content)[:400])
outStatus, outType, output = ipython_pb2.SUCCESS, None, None
# prepare the reply
if msg_type == 'stream':
outType = ipython_pb2.TEXT
output = content['text']
elif msg_type == 'error':
outStatus = ipython_pb2.ERROR
outType = ipython_pb2.TEXT
output = '\n'.join(content['traceback'])
elif msg_type in ('display_data', 'execute_result'):
if 'image/jpeg' in content['data']:
outType = ipython_pb2.JPEG
@ -75,7 +72,7 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
elif 'image/png' in content['data']:
outType = ipython_pb2.PNG
output = content['data']['image/png']
if 'text/plain' in content['data']:
elif 'text/plain' in content['data']:
outType = ipython_pb2.TEXT
output = content['data']['text/plain']
elif 'text/html' in content['data']:
@ -88,11 +85,17 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
elif 'application/vnd.holoviews_load.v0+json' in content['data']:
outType = ipython_pb2.HTML
output = '<script> ' + content['data']['application/vnd.holoviews_load.v0+json'] + ' </script>\n'
if outType is not None:
stream_reply_queue.put(
ipython_pb2.ExecuteResponse(status=outStatus,
type=outType,
output=output))
elif msg_type == 'error':
outStatus = ipython_pb2.ERROR
outType = ipython_pb2.TEXT
output = '\n'.join(content['traceback'])
# send reply if we supported the output type
if outType is not None:
stream_reply_queue.put(
ipython_pb2.ExecuteResponse(status=outStatus,
type=outType,
output=output))
def execute_worker():
reply = self._kc.execute_interactive(request.code,
output_hook=_output_hook,