(beam) branch master updated: Fix flaky unit test to pass post-submit checks (#39562)

[sh...@apache.org]

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

shunping 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 459b7ee5036 Fix flaky unit test to pass post-submit checks (#39562)
459b7ee5036 is described below

commit 459b7ee50368391a4a6881ceec3e06209188c255
Author: Ian Liao <55...@users.noreply.github.com>
AuthorDate: Thu Jul 30 21:07:39 2026 -0700

    Fix flaky unit test to pass post-submit checks (#39562)
---
 .../python/apache_beam/runners/interactive/recording_manager_test.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/interactive/recording_manager_test.py b/sdks/python/apache_beam/runners/interactive/recording_manager_test.py
index 55c3bd91cfd..b43d8aeb873 100644
--- a/sdks/python/apache_beam/runners/interactive/recording_manager_test.py
+++ b/sdks/python/apache_beam/runners/interactive/recording_manager_test.py
@@ -1139,7 +1139,10 @@ class RecordingManagerTest(unittest.TestCase):
         t.unique_name
         for t in graph2._pipeline_proto.components.transforms.values()
     ]
-    self.assertIn('Map1', transform_names)
+    self.assertTrue(
+        any('Map1' in name for name in transform_names),
+        f"Expected 'Map1' in one of the transform names, got: {transform_names}"
+    )
 
   def test_wait_for_completion_raises_exception_on_failure(self):
     future = Future()