Pass empty_match_treatment flag (#29251)

apache · Nov 3, 2023 · 04df11c · 04df11c
1 parent a3fe3fa
commit 04df11c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sdks/python/apache_beam/io/fileio.py b/sdks/python/apache_beam/io/fileio.py
@@ -195,7 +195,8 @@ def __init__(
     self._empty_match_treatment = empty_match_treatment
 
   def expand(self, pcoll) -> beam.PCollection[filesystem.FileMetadata]:
-    return pcoll.pipeline | beam.Create([self._file_pattern]) | MatchAll()
+    return pcoll.pipeline | beam.Create([self._file_pattern]) | MatchAll(
+        empty_match_treatment=self._empty_match_treatment)
 
 
 class MatchAll(beam.PTransform):