(beam) branch master updated: fix flaky Arm postcommit test collection on Python 3.14 (#38844)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 726933b81db fix flaky Arm postcommit test collection on Python 3.14 
(#38844)
726933b81db is described below

commit 726933b81dba6515ec73e1d1d5469f4f159f84dd
Author: Abdelrahman Ibrahim <abdoibrahim1...@gmail.com>
AuthorDate: Mon Jun 8 21:09:01 2026 +0200

    fix flaky Arm postcommit test collection on Python 3.14 (#38844)
    
    * fix flaky Arm postcommit test collection on Python 3.14
    
    * fix formatter
    
    ---------
    
    Co-authored-by: Yi Hu <ya...@google.com>
---
 .github/trigger_files/beam_PostCommit_Python.json |  2 +-
 sdks/python/apache_beam/dataframe/frames_test.py  | 33 ++++++++++++++---------
 2 files changed, 21 insertions(+), 14 deletions(-)

diff --git a/.github/trigger_files/beam_PostCommit_Python.json 
b/.github/trigger_files/beam_PostCommit_Python.json
index b12889937d5..21381329475 100644
--- a/.github/trigger_files/beam_PostCommit_Python.json
+++ b/.github/trigger_files/beam_PostCommit_Python.json
@@ -1,5 +1,5 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to 
run.",
   "pr": "38069",
-  "modification": 44
+  "modification": 48
 }
diff --git a/sdks/python/apache_beam/dataframe/frames_test.py 
b/sdks/python/apache_beam/dataframe/frames_test.py
index 2e560c01341..bb46f0e29be 100644
--- a/sdks/python/apache_beam/dataframe/frames_test.py
+++ b/sdks/python/apache_beam/dataframe/frames_test.py
@@ -2955,19 +2955,26 @@ class AllowNonParallelTest(unittest.TestCase):
       self._use_non_parallel_operation()
 
 
+_CONSTRUCTION_TIME_TEST_COLUMNS = [
+    'str_col', 'int_col', 'flt_col', 'cat_col', 'datetime_col'
+]
+
+
 class ConstructionTimeTest(unittest.TestCase):
   """Tests for operations that can be executed eagerly."""
-  DF = pd.DataFrame({
-      'str_col': ['foo', 'bar'] * 3,
-      'int_col': [1, 2] * 3,
-      'flt_col': [1.1, 2.2] * 3,
-      'cat_col': pd.Series(list('aabbca'), dtype="category"),
-      'datetime_col': pd.Series(
-          pd.date_range(
-              '1/1/2000', periods=6, freq='m', tz='America/Los_Angeles'))
-  })
-  DEFERRED_DF = frame_base.DeferredFrame.wrap(
-      expressions.PlaceholderExpression(DF.iloc[:0]))
+  @classmethod
+  def setUpClass(cls):
+    cls.DF = pd.DataFrame({
+        'str_col': ['foo', 'bar'] * 3,
+        'int_col': [1, 2] * 3,
+        'flt_col': [1.1, 2.2] * 3,
+        'cat_col': pd.Series(list('aabbca'), dtype="category"),
+        'datetime_col': pd.Series(
+            pd.date_range(
+                '1/1/2000', periods=6, freq='m', tz='America/Los_Angeles'))
+    })
+    cls.DEFERRED_DF = frame_base.DeferredFrame.wrap(
+        expressions.PlaceholderExpression(cls.DF.iloc[:0]))
 
   def _run_test(self, fn):
     expected = fn(self.DF)
@@ -2982,11 +2989,11 @@ class ConstructionTimeTest(unittest.TestCase):
     else:
       self.assertEqual(expected, actual)
 
-  @parameterized.expand(DF.columns)
+  @parameterized.expand(_CONSTRUCTION_TIME_TEST_COLUMNS)
   def test_series_name(self, col_name):
     self._run_test(lambda df: df[col_name].name)
 
-  @parameterized.expand(DF.columns)
+  @parameterized.expand(_CONSTRUCTION_TIME_TEST_COLUMNS)
   def test_series_dtype(self, col_name):
     self._run_test(lambda df: df[col_name].dtype)
     self._run_test(lambda df: df[col_name].dtypes)