[beam] branch master updated: [BEAM-9402] Remove options overwrite

[go...@apache.org]

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

goenka 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 e6d1420  [BEAM-9402] Remove options overwrite
     new facb4ef  Merge pull request #10997 from angoenka/fix_test_multi_triggered_gbk_side_input
e6d1420 is described below

commit e6d142087bd15a7b12661371fcb3572b218f7e42
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Thu Feb 27 18:16:43 2020 -0800

    [BEAM-9402] Remove options overwrite
---
 sdks/python/apache_beam/transforms/sideinputs_test.py | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/sdks/python/apache_beam/transforms/sideinputs_test.py b/sdks/python/apache_beam/transforms/sideinputs_test.py
index 20d2f6e..ddec122 100644
--- a/sdks/python/apache_beam/transforms/sideinputs_test.py
+++ b/sdks/python/apache_beam/transforms/sideinputs_test.py
@@ -27,8 +27,6 @@ import unittest
 from nose.plugins.attrib import attr
 
 import apache_beam as beam
-from apache_beam.options.pipeline_options import DebugOptions
-from apache_beam.options.pipeline_options import StandardOptions
 from apache_beam.testing.test_pipeline import TestPipeline
 from apache_beam.testing.test_stream import TestStream
 from apache_beam.testing.util import assert_that
@@ -349,11 +347,10 @@ class SideInputsTest(unittest.TestCase):
     # This flag is only necessary when using the multi-output TestStream b/c
     # it relies on using the PCollection output tags as the PCollection output
     # ids.
-    options = StandardOptions(streaming=True)
-    options.view_as(DebugOptions).add_experiment(
-        'passthrough_pcollection_output_ids')
-
-    p = TestPipeline(options=options)
+    p = TestPipeline(
+        additional_pipeline_args=[
+            '--experiments=' + 'passthrough_pcollection_output_ids'
+        ])
 
     test_stream = (
         p