You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ro...@apache.org on 2018/10/04 08:40:58 UTC

[beam] 01/01: Actually use opts.

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch fn-api-wordcount-test
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 81866eaa4046be80018a3b736f33e37fa72286d1
Author: Robert Bradshaw <ro...@google.com>
AuthorDate: Thu Oct 4 10:40:14 2018 +0200

    Actually use opts.
---
 sdks/python/apache_beam/examples/wordcount_it_test.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/sdks/python/apache_beam/examples/wordcount_it_test.py b/sdks/python/apache_beam/examples/wordcount_it_test.py
index 05a78eb..ee9cee7 100644
--- a/sdks/python/apache_beam/examples/wordcount_it_test.py
+++ b/sdks/python/apache_beam/examples/wordcount_it_test.py
@@ -65,6 +65,7 @@ class WordCountIT(unittest.TestCase):
                                               sleep_secs)]
     extra_opts = {'output': output,
                   'on_success_matcher': all_of(*pipeline_verifiers)}
+    extra_opts.update(opts)
 
     # Register clean up before pipeline execution
     self.addCleanup(delete_files, [output + '*'])