[beam] branch master updated: [BEAM-9499] Sickbay test_multi_triggered_gbk_side_input for streaming mode

[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 4d13e34  [BEAM-9499] Sickbay test_multi_triggered_gbk_side_input for streaming mode
     new bbcb499  Merge pull request #11121 from angoenka/sickbay_for_streaming
4d13e34 is described below

commit 4d13e3428fbfd61d30c1605c273bbd6b32f3b664
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Fri Mar 13 02:16:13 2020 -0700

    [BEAM-9499] Sickbay test_multi_triggered_gbk_side_input for streaming mode
---
 sdks/python/apache_beam/transforms/sideinputs_test.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/transforms/sideinputs_test.py b/sdks/python/apache_beam/transforms/sideinputs_test.py
index 7c43e6b..6c943f0 100644
--- a/sdks/python/apache_beam/transforms/sideinputs_test.py
+++ b/sdks/python/apache_beam/transforms/sideinputs_test.py
@@ -340,7 +340,8 @@ class SideInputsTest(unittest.TestCase):
     assert_that(results, equal_to(['a', 'b']))
     pipeline.run()
 
-  @attr('ValidatesRunner', 'sickbay-batch')
+  # TODO(BEAM-9499): Disable this test in streaming temporarily.
+  @attr('ValidatesRunner', 'sickbay-batch', 'sickbay-streaming')
   def test_multi_triggered_gbk_side_input(self):
     """Test a GBK sideinput, with multiple triggering."""
     # TODO(BEAM-9322): Remove use of this experiment.