File tree Expand file tree Collapse file tree
wayang-api/wayang-api-python/src/test/java/org/apache/wayang/api/python Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1818package org .apache .wayang .api .python ;
1919
2020import java .util .List ;
21+ import java .nio .file .Paths ;
2122
2223import org .apache .wayang .api .python .executor .PythonProcessCaller ;
2324import org .apache .wayang .api .python .function .WrappedMapPartitionsDescriptor ;
@@ -37,10 +38,9 @@ class PythonApiTests {
3738 @ Test
3839 void processCallerSocketTest () {
3940 final Configuration configuration = new Configuration ();
40-
41- configuration .setProperty ("wayang.api.python.worker" , "/var/www/html/python/src/pywy/execution/worker.py" );
42- configuration .setProperty ("wayang.api.python.path" , "python3" );
43- configuration .setProperty ("wayang.api.python.worker" , "/usr/local/lib/python3.8/dist-packages" );
41+ final String path = Paths .get ("python/worker.py" ).toString ();
42+
43+ configuration .setProperty ("wayang.api.python.worker" , path );
4444
4545 final PythonProcessCaller processCaller = new PythonProcessCaller ();
4646
@@ -65,7 +65,7 @@ void WrappedMapPartitionsDescriptorTest() throws Exception {
6565
6666 final Iterable <String > input = List .of ("wayang" );
6767
68- descriptor .getJavaImplementation ().apply (input );
68+ assertTrue ( descriptor .getJavaImplementation ().apply (input ) != null );
6969 }
7070
7171 @ Test
You can’t perform that action at this time.
0 commit comments