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 tests

Browse source
This commit is contained in:
oxygen311 2018-08-08 12:35:54 +02:00
parent ad8d07f5e5
commit 54004b0986
2 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java
View file

@ -185,6 +185,22 @@ public abstract class BasePythonInterpreterTest {
interpreterResultMessages = context.out.toInterpreterResultMessage();
assertEquals(1, interpreterResultMessages.size());
assertEquals("there is no Error: ok\n", interpreterResultMessages.get(0).getData());
// ZEPPELIN-3687
context = getInterpreterContext();
result = interpreter.interpret("# print('Hello')", context);
Thread.sleep(100);
assertEquals(InterpreterResult.Code.SUCCESS, result.code());
interpreterResultMessages = context.out.toInterpreterResultMessage();
assertEquals(0, interpreterResultMessages.size());
context = getInterpreterContext();
result = interpreter.interpret(
"# print('Hello')\n# print('How are u?')\n# time.sleep(1)", context);
Thread.sleep(100);
assertEquals(InterpreterResult.Code.SUCCESS, result.code());
interpreterResultMessages = context.out.toInterpreterResultMessage();
assertEquals(0, interpreterResultMessages.size());
}
@Test

11
python/src/test/java/org/apache/zeppelin/python/PythonInterpreterTest.java
View file

@ -26,7 +26,6 @@ import org.apache.zeppelin.interpreter.LazyOpenInterpreter;
import org.junit.Test;
import java.io.IOException;
import java.util.Collections;
import java.util.LinkedList;
import java.util.Properties;
import java.util.regex.Matcher;
@ -106,14 +105,4 @@ public class PythonInterpreterTest extends BasePythonInterpreterTest {
t.join(2000);
assertFalse(t.isAlive());
}
@Test
public void testOnlyCommentsJob() throws InterpreterException {
final String code = "# print('hello')";
InterpreterResult ret = interpreter.interpret(code, getInterpreterContext());
assertNotNull(ret);
assertEquals(InterpreterResult.Code.SUCCESS, ret.code());
assertEquals(Collections.emptyList(), ret.message());
}
}