This is an automated email from the ASF dual-hosted git repository.
yichi 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 3da3076313b Allow unsafe triggers for python nexmark benchmarks
(#22596)
3da3076313b is described below
commit 3da3076313bb2ecbb82d8347c160eafb8a917b5f
Author: Yichi Zhang <[email protected]>
AuthorDate: Fri Aug 5 10:17:05 2022 -0700
Allow unsafe triggers for python nexmark benchmarks (#22596)
---
sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py
b/sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py
index 89b6dce2b58..e4babe5f42e 100644
--- a/sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py
+++ b/sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py
@@ -69,6 +69,7 @@ from apache_beam.options.pipeline_options import
GoogleCloudOptions
from apache_beam.options.pipeline_options import PipelineOptions
from apache_beam.options.pipeline_options import SetupOptions
from apache_beam.options.pipeline_options import StandardOptions
+from apache_beam.options.pipeline_options import TypeOptions
from apache_beam.runners import PipelineState
from apache_beam.testing.benchmarks.nexmark import nexmark_util
from apache_beam.testing.benchmarks.nexmark.monitor import Monitor
@@ -180,6 +181,7 @@ class NexmarkLauncher(object):
# Usage with Dataflow requires a project to be supplied.
self.project = self.pipeline_options.view_as(GoogleCloudOptions).project
self.streaming = self.pipeline_options.view_as(StandardOptions).streaming
+ self.pipeline_options.view_as(TypeOptions).allow_unsafe_triggers = True
if self.streaming:
if self.args.subscription_name is None or self.project is None:
