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 lint

Browse source
This commit is contained in:
marc hurabielle 2019-04-29 21:36:58 +09:00
parent 6e48c13805
commit 5bed19496d
2 changed files with 23 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -87,8 +87,8 @@ class IPython(ipython_pb2_grpc.IPythonServicer):
payload_reply = []
def execute_worker():
reply = self._kc.execute_interactive(request.code,
output_hook=_output_hook,
timeout=None)
output_hook=_output_hook,
timeout=None)
payload_reply.append(reply)
t = threading.Thread(name="ConsumerThread", target=execute_worker)

44
python/src/test/java/org/apache/zeppelin/python/IPythonInterpreterTest.java
View file

@ -301,33 +301,31 @@ public class IPythonInterpreterTest extends BasePythonInterpreterTest {
// The goal of this test is to ensure that concurrent interpret and complete
// will not make execute hang forever.
// ExecutorService pool = Executors.newFixedThreadPool(2);
// FutureTask<InterpreterResult> interpretFuture =
// new FutureTask(new Callable() {
// @Override
// public Object call() throws Exception {
// return interpreter.interpret(code, getInterpreterContext());
// }
// });
// FutureTask<List<InterpreterCompletion>> completionFuture =
// new FutureTask(new Callable() {
// @Override
// public Object call() throws Exception {
// return interpreter.completion(base, base.length(), null);
// }
// });
ExecutorService pool = Executors.newFixedThreadPool(2);
FutureTask<InterpreterResult> interpretFuture =
new FutureTask(new Callable() {
@Override
public Object call() throws Exception {
return interpreter.interpret(code, getInterpreterContext());
}
});
FutureTask<List<InterpreterCompletion>> completionFuture =
new FutureTask(new Callable() {
@Override
public Object call() throws Exception {
return interpreter.completion(base, base.length(), getInterpreterContext());
}
});
// pool.execute(interpretFuture);
pool.execute(interpretFuture);
// we sleep to ensure that the paragraph is running
// Thread.sleep(3000);
// pool.execute(completionFuture);
Thread.sleep(3000);
pool.execute(completionFuture);
// We ensure that running and auto completion are not hanging.
// InterpreterResult res = interpretFuture.get(20000, TimeUnit.MILLISECONDS);
// List<InterpreterCompletion> autoRes = completionFuture.get(1000, TimeUnit.MILLISECONDS);
InterpreterResult res = interpreter.interpret(code, getInterpreterContext());
List<InterpreterCompletion> autoRes = interpreter.completion(base, base.length(), null);
assertTrue(res.code().name().equals("SUCCESS"));
InterpreterResult res = interpretFuture.get(20000, TimeUnit.MILLISECONDS);
List<InterpreterCompletion> autoRes = completionFuture.get(1000, TimeUnit.MILLISECONDS);
assertTrue(res.code().name().equals("SUCCESS"));
assertTrue(autoRes.size() > 0);
}