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

increase queue size

Browse source
This commit is contained in:
marc hurabielle 2019-03-24 12:39:14 +09:00
parent 42f3ca097e
commit e1d37b76ea
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -53,7 +53,7 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
print("execute code:\n")
print(request.code.encode('utf-8'))
sys.stdout.flush()
stream_reply_queue = queue.Queue(maxsize = 20)
stream_reply_queue = queue.Queue(maxsize = 30)
payload_reply = []
def _output_hook(msg):
msg_type = msg['header']['msg_type']
@ -91,7 +91,6 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
if outtype:
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,