[python] Enable tests that were fixed on multihost.

blp · blp · commit c541719cc4c6 · 2026-02-27T20:13:04.000Z
Signed-off-by: Ben Pfaff &lt;blp@feldera.com&gt;
diff --git a/python/tests/platform/test_ingress_formats.py b/python/tests/platform/test_ingress_formats.py
@@ -15,8 +15,6 @@
     get,
 )
 
-from feldera.testutils import single_host_only
-
 
 def _ingress_and_wait_token(
     pipeline: str,
@@ -408,7 +406,6 @@ def test_primary_keys(pipeline_name):
 
 
 @gen_pipeline_name
-@single_host_only
 def test_case_sensitive_tables(pipeline_name):
     """
     - Distinguish between quoted and unquoted identifiers.
@@ -456,7 +453,6 @@ def test_case_sensitive_tables(pipeline_name):
 
 
 @gen_pipeline_name
-@single_host_only
 def test_duplicate_outputs(pipeline_name):
     """
     multiple inserts producing duplicate output values.
@@ -506,7 +502,6 @@ def test_duplicate_outputs(pipeline_name):
 
 
 @gen_pipeline_name
-@single_host_only
 def test_upsert(pipeline_name):
     """
     - Insert several rows with composite PK.
diff --git a/python/tests/platform/test_shared_pipeline.py b/python/tests/platform/test_shared_pipeline.py
@@ -92,7 +92,6 @@ def test_get_pipeline_stats(self):
         assert stats.get("inputs") is not None
         assert stats.get("outputs") is not None
 
-    @single_host_only
     def test_case_sensitive_views_listen(self):
         self.pipeline.start_paused()
 
@@ -210,7 +209,6 @@ def test_pipeline_get(self):
         assert df.shape[0] == 100
         self.pipeline.stop(force=True)
 
-    @single_host_only
     def test_local_listen_after_start(self):
         df_students = pd.read_csv("tests/assets/students.csv")
         df_grades = pd.read_csv("tests/assets/grades.csv")
@@ -743,7 +741,6 @@ def test_support_bundle_with_selectors(self):
             assert len(file_list) >= 2
             assert "manifest.txt" in file_list
 
-    @single_host_only
     def test_url_encoding_ingress_egress_table_name(self):
         """
         CREATE TABLE "t1#a1" (
@@ -790,13 +787,11 @@ def test_url_encoding_ingress_egress_table_name(self):
         ]
         self.assertCountEqual(egress_result, expected_egress)
 
-    @single_host_only
     def test_listen_non_existent_view_paused(self):
         self.pipeline.start_paused()
         with self.assertRaises(ValueError):
             self.pipeline.listen("FrodoBagginsInMordor")
 
-    @single_host_only
     def test_listen_non_existent_view_running(self):
         self.pipeline.start()
         with self.assertRaises(ValueError):
