We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9833089 commit 017f1ffCopy full SHA for 017f1ff
joblibspark/backend.py
@@ -110,10 +110,12 @@ def __init__(self,
110
111
self._is_spark_connect_mode = is_spark_connect_mode()
112
if self._is_spark_connect_mode:
113
+ """
114
if Version(pyspark.__version__).major < 4:
115
raise RuntimeError(
116
"Joblib spark does not support Spark Connect with PySpark version < 4."
117
)
118
119
self._support_stage_scheduling = True
120
self._spark_supports_job_cancelling = True
121
else:
0 commit comments