From 25a8fbca1bc35a753d4b95e84c8993b90a23373c Mon Sep 17 00:00:00 2001 From: Ruifeng Zheng Date: Fri, 10 Oct 2025 10:02:32 +0800 Subject: [PATCH] test --- python/pyspark/sql/tests/test_observation.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/python/pyspark/sql/tests/test_observation.py b/python/pyspark/sql/tests/test_observation.py index 5af709d191c12..37ebe9c9a6f14 100644 --- a/python/pyspark/sql/tests/test_observation.py +++ b/python/pyspark/sql/tests/test_observation.py @@ -25,7 +25,7 @@ PySparkValueError, ) from pyspark.testing.sqlutils import ReusedSQLTestCase -from pyspark.testing.utils import assertDataFrameEqual +from pyspark.testing.utils import assertDataFrameEqual, eventually class DataFrameObservationTestsMixin: @@ -214,6 +214,7 @@ def test_observe_with_array_type(self): self.assertEqual(observation.get, {"array": [10]}) + @eventually(timeout=60.0, catch_assertions=True) def test_observe_with_map_type(self): observation = Observation("map")