From b91dbf3319695be59eb43d63383aeb1ae2b2c1d7 Mon Sep 17 00:00:00 2001 From: bvolpato Date: Thu, 6 Aug 2026 22:20:05 -0400 Subject: [PATCH] [Python] Deflake TextIO footer test --- sdks/python/apache_beam/io/textio_test.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/sdks/python/apache_beam/io/textio_test.py b/sdks/python/apache_beam/io/textio_test.py index 3854a22640a9..f5f2860d3ee5 100644 --- a/sdks/python/apache_beam/io/textio_test.py +++ b/sdks/python/apache_beam/io/textio_test.py @@ -1677,9 +1677,10 @@ def test_write_pipeline_footer(self): with TestPipeline() as pipeline: footer_text = 'footer' pcoll = pipeline | beam.core.Create(self.lines) - pcoll | 'Write' >> WriteToText( # pylint: disable=expression-not-assigned - self.path, - footer=footer_text) + pcoll | 'Write' >> WriteToText( # pylint: disable=expression-not-assigned + self.path, + shard_name_template='', + footer=footer_text) read_result = [] for file_name in glob.glob(self.path + '*'):