Skip to content

Commit d521df8

Browse files
authored
use local variable (#38850)
1 parent 0eac038 commit d521df8

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

sdks/python/apache_beam/io/fileio.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -313,9 +313,10 @@ def expand(self, pbegin) -> beam.PCollection[filesystem.FileMetadata]:
313313
fire_interval=self.interval)
314314

315315
# match file pattern periodically
316+
file_pattern = self.file_pattern
316317
match_files = (
317318
impulse
318-
| 'GetFilePattern' >> beam.Map(lambda x: self.file_pattern)
319+
| 'GetFilePattern' >> beam.Map(lambda x: file_pattern)
319320
| MatchAll(self.empty_match_treatment))
320321

321322
# apply deduplication strategy if required

0 commit comments

Comments
 (0)