diff --git a/python/pyspark/sql/tests/connect/test_parity_functions.py b/python/pyspark/sql/tests/connect/test_parity_functions.py index 3d390c13913fa..1ea33d2e37023 100644 --- a/python/pyspark/sql/tests/connect/test_parity_functions.py +++ b/python/pyspark/sql/tests/connect/test_parity_functions.py @@ -54,7 +54,7 @@ def test_lit_np_scalar(self): super().test_lit_np_scalar() def test_raise_error(self): - self.check_assert_true(SparkConnectException) + self.check_raise_error(SparkConnectException) # Comparing column type of connect and pyspark @unittest.skip("Fails in Spark Connect, should enable.")