[beam] branch fn-api-wordcount-test created (now 81866ea)

[ro...@apache.org]

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

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


      at 81866ea  Actually use opts.

This branch includes the following new commits:

     new 81866ea  Actually use opts.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[beam] 01/01: Actually use opts.

[ro...@apache.org]

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 + '*'])