You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ru...@apache.org on 2024/05/17 03:57:51 UTC
(spark) branch master updated: [SPARK-41625][PYTHON][CONNECT][TESTS][FOLLOW-UP] Enable `DataFrameObservationParityTests.test_observe_str`
This is an automated email from the ASF dual-hosted git repository.
ruifengz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 889820c1ff39 [SPARK-41625][PYTHON][CONNECT][TESTS][FOLLOW-UP] Enable `DataFrameObservationParityTests.test_observe_str`
889820c1ff39 is described below
commit 889820c1ff392983c52b55d80bd8d80be22785ab
Author: Hyukjin Kwon <gu...@apache.org>
AuthorDate: Fri May 17 11:57:34 2024 +0800
[SPARK-41625][PYTHON][CONNECT][TESTS][FOLLOW-UP] Enable `DataFrameObservationParityTests.test_observe_str`
### What changes were proposed in this pull request?
This PR proposes to enable `DataFrameObservationParityTests.test_observe_str`.
### Why are the changes needed?
To make sure on the test coverage
### Does this PR introduce _any_ user-facing change?
No, test-only.
### How was this patch tested?
CI in this PR.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #46630 from HyukjinKwon/SPARK-41625-followup.
Authored-by: Hyukjin Kwon <gu...@apache.org>
Signed-off-by: Ruifeng Zheng <ru...@apache.org>
---
python/pyspark/sql/tests/connect/test_parity_observation.py | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/python/pyspark/sql/tests/connect/test_parity_observation.py b/python/pyspark/sql/tests/connect/test_parity_observation.py
index a7b0009357b6..e16053d5a082 100644
--- a/python/pyspark/sql/tests/connect/test_parity_observation.py
+++ b/python/pyspark/sql/tests/connect/test_parity_observation.py
@@ -25,10 +25,7 @@ class DataFrameObservationParityTests(
DataFrameObservationTestsMixin,
ReusedConnectTestCase,
):
- # TODO(SPARK-41625): Support Structured Streaming
- @unittest.skip("Fails in Spark Connect, should enable.")
- def test_observe_str(self):
- super().test_observe_str()
+ pass
if __name__ == "__main__":
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org