diff --git a/dev/sparktestsupport/modules.py b/dev/sparktestsupport/modules.py
index 306a3b69223f..ee2a953a7402 100644
--- a/dev/sparktestsupport/modules.py
+++ b/dev/sparktestsupport/modules.py
@@ -1566,11 +1566,13 @@ def __hash__(self):
     dependencies=[pyspark_core, pyspark_sql, pyspark_connect],
     source_file_regexes=["python/pyspark/pipelines"],
     python_test_goals=[
+        "pyspark.pipelines.tests.test_add_pipeline_analysis_context",
         "pyspark.pipelines.tests.test_block_session_mutations",
         "pyspark.pipelines.tests.test_cli",
         "pyspark.pipelines.tests.test_decorators",
         "pyspark.pipelines.tests.test_graph_element_registry",
         "pyspark.pipelines.tests.test_init_cli",
+        "pyspark.pipelines.tests.test_spark_connect",
     ],
 )
 
diff --git a/python/pyspark/pipelines/tests/test_spark_connect.py b/python/pyspark/pipelines/tests/test_spark_connect.py
index 0b54c0906f9a..3027de46864f 100644
--- a/python/pyspark/pipelines/tests/test_spark_connect.py
+++ b/python/pyspark/pipelines/tests/test_spark_connect.py
@@ -58,7 +58,7 @@ def mv():
             refresh=None,
             full_refresh_all=False,
             dry=True,
-            storage="storage_path",
+            storage="file:///tmp/storage_path",
         )
         handle_pipeline_events(result_iter)
 
@@ -80,7 +80,7 @@ def st():
             refresh=None,
             full_refresh_all=False,
             dry=True,
-            storage="storage_path",
+            storage="file:///tmp/storage_path",
         )
         with self.assertRaises(AnalysisException) as context:
             handle_pipeline_events(result_iter)