This is an automated email from the ASF dual-hosted git repository. zkaoudi pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 1e0f9e8166225176fe3022de5fbcce3dbcba96b9 Merge: 3ade29109 26f939cf9 Author: Zoi Kaoudi <[email protected]> AuthorDate: Mon Nov 17 09:48:43 2025 +0100 Merge pull request #603 from mspruc/main python api tests & code cleanup .github/workflows/backend.yml | 17 +- python/README.md | 3 + .../pywy/{tests/json_test.py => requirements.txt} | 23 +- .../src/pywy/tests/{json_test.py => conftest.py} | 20 +- python/src/pywy/tests/filter_test.py | 40 ---- python/src/pywy/tests/join_test.py | 45 ---- .../tests/{json_test.py => resources/__init__.py} | 19 -- .../src/pywy/tests}/resources/plan-a.json | 4 +- python/src/pywy/tests/resources/sample_data.md | 264 +++++++++++++++++++++ .../src/pywy/tests/resources}/wayang.properties | 9 +- .../pywy/tests/resources/wordcount_out_python.txt | 7 - python/src/pywy/tests/test.py | 78 ------ .../pywy/tests/test_decision_tree_regression.py | 67 +++--- python/src/pywy/tests/test_dl.py | 78 ++++++ python/src/pywy/tests/test_filter.py | 65 +++++ python/src/pywy/tests/test_json.py | 52 ++++ python/src/pywy/tests/test_train_linear_svc.py | 35 ++- python/src/pywy/tests/test_word_count.py | 95 ++++++++ python/src/pywy/tests/train_logistic_test.py | 32 ++- python/src/pywy/tests/word_count.py | 71 ------ tools/test/config/wayang.properties | 5 + .../wayang-api-json/src/main/resources/plan-a.json | 4 +- .../src/main/scala/builder/JsonPlanBuilder.scala | 2 +- wayang-api/wayang-api-python/pom.xml | 2 - .../wayang/api/python/executor/ProcessFeeder.java | 104 ++++---- .../api/python/executor/ProcessReceiver.java | 23 +- .../api/python/executor/PythonProcessCaller.java | 94 ++++---- .../api/python/executor/PythonWorkerManager.java | 34 ++- .../wayang/api/python/executor/ReaderIterator.java | 72 +++--- .../python/function/WrappedFlatMapDescriptor.java | 34 ++- .../function/WrappedMapPartitionsDescriptor.java | 44 ++-- .../function/WrappedPredicateDescriptor.java | 45 ++-- .../api/python/function/WrappedPythonFunction.java | 16 +- .../python/function/WrappedReduceDescriptor.java | 35 ++- .../function/WrappedTransformationDescriptor.java | 39 ++- .../apache/wayang/api/python/PythonApiTests.java | 44 ++++ .../src/test/resources}/wayang.properties | 13 +- 37 files changed, 966 insertions(+), 668 deletions(-) diff --cc wayang-api/wayang-api-python/pom.xml index 3388f1582,662ba1cf3..2b45dbe4e --- a/wayang-api/wayang-api-python/pom.xml +++ b/wayang-api/wayang-api-python/pom.xml @@@ -60,11 -60,9 +60,9 @@@ <dependency> <groupId>org.apache.wayang</groupId> <artifactId>wayang-java</artifactId> - <version>1.1.0</version> + <version>1.1.1-SNAPSHOT</version> <scope>test</scope> - </dependency> - <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId>
