This is an automated email from the ASF dual-hosted git repository.
jrmccluskey 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 62357960fc3 Remove a race with another file write that is not
essential to test presence of duplicates. (#40596)
62357960fc3 is described below
commit 62357960fc3114da572ef549287da4566699f770
Author: tvalentyn <[email protected]>
AuthorDate: Mon Oct 19 08:35:00 2026 -0700
Remove a race with another file write that is not essential to test
presence of duplicates. (#40596)
* Remove a race with another file write that is not essential to test
presence of duplicates.
* Replace removed functionality.
---
sdks/python/apache_beam/io/fileio_test.py | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
diff --git a/sdks/python/apache_beam/io/fileio_test.py
b/sdks/python/apache_beam/io/fileio_test.py
index 1c650653804..3bb250a34bd 100644
--- a/sdks/python/apache_beam/io/fileio_test.py
+++ b/sdks/python/apache_beam/io/fileio_test.py
@@ -366,13 +366,6 @@ class MatchContinuouslyTest(_TestCaseWithTempDirCleanUp):
file = self._create_temp_file(dir=tempdir)
# Add file twice, since it will be matched for every interval
files += [file, file]
- # Add file name that will be created mid-pipeline
- files.append(FileSystems.join(tempdir, 'extra'))
-
- def _create_extra_file(element):
- writer = FileSystems.create(FileSystems.join(tempdir, 'extra'))
- writer.close()
- return element.path
with TestPipeline() as p:
match_continiously = (
@@ -383,8 +376,7 @@ class MatchContinuouslyTest(_TestCaseWithTempDirCleanUp):
has_deduplication=False,
start_timestamp=start,
stop_timestamp=stop)
- | beam.Map(_create_extra_file))
-
+ | beam.Map(lambda element: element.path))
assert_that(match_continiously, equal_to(files))
def test_match_updated_files(self):
