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 + '*'):