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 833b4a6eb2f3 [SPARK-55627][PYTHON][TESTS] Put CustomChannelBuilder 
inside should_test_connect
833b4a6eb2f3 is described below

commit 833b4a6eb2f3894d5dcdaeaf9965240e4afc2fdf
Author: Tian Gao <[email protected]>
AuthorDate: Mon Feb 23 07:32:12 2026 +0900

    [SPARK-55627][PYTHON][TESTS] Put CustomChannelBuilder inside 
should_test_connect
    
    ### What changes were proposed in this pull request?
    
    In `test_session.py`, `CustomChannelBuilder` is put into the 
`should_test_connect` protection.
    
    ### Why are the changes needed?
    
    `DefaultChannelBuilder` only exists when we test connect. This test fails 
in classic only CI.
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    CI.
    
    ### Was this patch authored or co-authored using generative AI tooling?
    
    No.
    
    Closes #54417 from gaogaotiantian/fix-test-session.
    
    Authored-by: Tian Gao <[email protected]>
    Signed-off-by: Hyukjin Kwon <[email protected]>
---
 python/pyspark/sql/tests/connect/test_session.py | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/python/pyspark/sql/tests/connect/test_session.py 
b/python/pyspark/sql/tests/connect/test_session.py
index 0c64b558be5f..385dcbd218ef 100644
--- a/python/pyspark/sql/tests/connect/test_session.py
+++ b/python/pyspark/sql/tests/connect/test_session.py
@@ -27,11 +27,10 @@ if should_test_connect:
     from pyspark.sql.connect.client import DefaultChannelBuilder
     from pyspark.sql.connect.session import SparkSession as RemoteSparkSession
 
-
-class CustomChannelBuilder(DefaultChannelBuilder):
-    @property
-    def userId(self) -> Optional[str]:
-        return "abc"
+    class CustomChannelBuilder(DefaultChannelBuilder):
+        @property
+        def userId(self) -> Optional[str]:
+            return "abc"
 
 
 @unittest.skipIf(not should_test_connect, connect_requirement_message)


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to