This is an automated email from the ASF dual-hosted git repository.
ahmedabu98 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 d521df8f1ed use local variable (#38850)
d521df8f1ed is described below
commit d521df8f1ed7f904d7aae1e544a55cb79190c093
Author: Ahmed Abualsaud <[email protected]>
AuthorDate: Mon Jun 8 16:41:17 2026 -0400
use local variable (#38850)
---
sdks/python/apache_beam/io/fileio.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/fileio.py
b/sdks/python/apache_beam/io/fileio.py
index 7c835074326..a333b7c8977 100644
--- a/sdks/python/apache_beam/io/fileio.py
+++ b/sdks/python/apache_beam/io/fileio.py
@@ -313,9 +313,10 @@ class MatchContinuously(beam.PTransform):
fire_interval=self.interval)
# match file pattern periodically
+ file_pattern = self.file_pattern
match_files = (
impulse
- | 'GetFilePattern' >> beam.Map(lambda x: self.file_pattern)
+ | 'GetFilePattern' >> beam.Map(lambda x: file_pattern)
| MatchAll(self.empty_match_treatment))
# apply deduplication strategy if required
