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 <[email protected]>
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()
