more

Author: sryza

dev/sparktestsupport/modules.py

@@ -555,8 +555,8 @@ def __hash__(self):
         "pyspark.sql.tests.pandas.test_pandas_udf_typehints_with_future_annotations",
         "pyspark.sql.tests.pandas.test_pandas_udf_window",
         "pyspark.sql.tests.pandas.test_pandas_sqlmetrics",
-        "pyspark.sql.tests.pandas.test_block_connect_access",
-        "pyspark.sql.tests.pipelines.test_blocking_connect_access"
+        "pyspark.sql.tests.pandas.test_converter",
+        "pyspark.sql.tests.pipelines.test_block_connect_access"
         "pyspark.sql.tests.pipelines.test_cli",
         "pyspark.sql.tests.pipelines.test_decorators",
         "pyspark.sql.tests.pipelines.test_graph_element_registry",

python/pyspark/sql/pipelines/cli.py

@@ -22,7 +22,6 @@
     $ bin/spark-pipelines run --spec /path/to/pipeline.yaml
 """
 from contextlib import contextmanager
-from threading import Thread
 import argparse
 import importlib.util
 import os