You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by go...@apache.org on 2020/03/16 19:30:24 UTC
[beam] branch master updated: [BEAM-9504] Sickbay streaming test
for batch VR
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 61da25f [BEAM-9504] Sickbay streaming test for batch VR
new 08c975a Merge pull request #11129 from angoenka/sickbay_test_streaming_pipeline_returns_expected_user_metrics_fnapi_it
61da25f is described below
commit 61da25f9fadba0d87283731c89c95db0922205d5
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Fri Mar 13 14:52:38 2020 -0700
[BEAM-9504] Sickbay streaming test for batch VR
---
.../dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py b/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
index 16fee92..353d32e 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
@@ -114,7 +114,8 @@ class ExerciseStreamingMetricsPipelineTest(unittest.TestCase):
argv = self.test_pipeline.get_full_options_as_args(**extra_opts)
return dataflow_exercise_streaming_metrics_pipeline.run(argv)
- @attr('IT', 'ValidatesRunner')
+ # Need not run streaming test in batch mode.
+ @attr('IT', 'ValidatesRunner', 'sickbay-batch')
def test_streaming_pipeline_returns_expected_user_metrics_fnapi_it(self):
"""
Runs streaming Dataflow job and verifies that user metrics are reported