This is an automated email from the ASF dual-hosted git repository.
gurwls223 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 8819828a4013 [SPARK-52853][TESTS][FOLLOW-UP] Import SDP module when
connect dependencies are available
8819828a4013 is described below
commit 8819828a401355e354f9ed6fd737047c6c92c6e9
Author: Hyukjin Kwon <[email protected]>
AuthorDate: Mon Jul 28 16:34:14 2025 +0900
[SPARK-52853][TESTS][FOLLOW-UP] Import SDP module when connect dependencies
are available
### What changes were proposed in this pull request?
This PR is a followup of https://github.com/apache/spark/pull/51590 that
imports SDP module when connect dependencies are available
### Why are the changes needed?
To make the builds without Spark Connect dependencies work, e.g.,
https://github.com/apache/spark/actions/runs/16552497456/job/46809414074
### Does this PR introduce _any_ user-facing change?
No, test-only.
### How was this patch tested?
Manually.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #51680 from HyukjinKwon/SPARK-52853-followup.
Authored-by: Hyukjin Kwon <[email protected]>
Signed-off-by: Hyukjin Kwon <[email protected]>
---
.../pyspark/pipelines/tests/test_block_session_mutations.py | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/python/pyspark/pipelines/tests/test_block_session_mutations.py
b/python/pyspark/pipelines/tests/test_block_session_mutations.py
index 771321d73832..3384a5fcbfb3 100644
--- a/python/pyspark/pipelines/tests/test_block_session_mutations.py
+++ b/python/pyspark/pipelines/tests/test_block_session_mutations.py
@@ -25,11 +25,12 @@ from pyspark.testing.connectutils import (
connect_requirement_message,
)
-from pyspark.pipelines.block_session_mutations import (
- block_session_mutations,
- BLOCKED_METHODS,
- ERROR_CLASS,
-)
+if should_test_connect:
+ from pyspark.pipelines.block_session_mutations import (
+ block_session_mutations,
+ BLOCKED_METHODS,
+ ERROR_CLASS,
+ )
@unittest.skipIf(not should_test_connect, connect_requirement_message or
"Connect not available")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
