This is an automated email from the ASF dual-hosted git repository.
pabloem 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 d333b2c Fix flaky interactive_runner_test
new 02f6f05 Merge pull request #11337 from Fix flaky
interactive_runner_test
d333b2c is described below
commit d333b2c5225d12a87b2cbcad1b573c23bebafbef
Author: Sam Rohde <[email protected]>
AuthorDate: Tue Apr 7 13:08:59 2020 -0700
Fix flaky interactive_runner_test
Change-Id: I98b26f8c149430814b2a9c7fc4fa5d508b7c8215
---
sdks/python/apache_beam/runners/interactive/interactive_runner_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/sdks/python/apache_beam/runners/interactive/interactive_runner_test.py
b/sdks/python/apache_beam/runners/interactive/interactive_runner_test.py
index 45ef110..cd6887d 100644
--- a/sdks/python/apache_beam/runners/interactive/interactive_runner_test.py
+++ b/sdks/python/apache_beam/runners/interactive/interactive_runner_test.py
@@ -164,7 +164,7 @@ class InteractiveRunnerTest(unittest.TestCase):
# Add the TestStream so that it can be cached.
ib.options.capturable_sources.add(TestStream)
- ib.options.capture_duration = timedelta(seconds=1)
+ ib.options.capture_duration = timedelta(seconds=5)
p = beam.Pipeline(
runner=interactive_runner.InteractiveRunner(),
