[beam] branch master updated: Better error for disabling runner v2 with cross language pipelines. (#23669)

[tv...@apache.org]

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

tvalentyn 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 00e55256922 Better error for disabling runner v2 with cross language pipelines. (#23669)
00e55256922 is described below

commit 00e55256922d632454f1053a0d721eb3c96afae2
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Mon Oct 17 18:24:09 2022 -0700

    Better error for disabling runner v2 with cross language pipelines. (#23669)
    
    Co-authored-by: tvalentyn <tv...@users.noreply.github.com>
---
 sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index cf209ad7247..e16c88ea9ee 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -418,6 +418,10 @@ class DataflowRunner(PipelineRunner):
 
     debug_options = options.view_as(DebugOptions)
     if pipeline_proto or pipeline.contains_external_transforms:
+      if debug_options.lookup_experiment('disable_runner_v2'):
+        raise ValueError(
+            'This pipeline contains cross language transforms, '
+            'which require runner v2.')
       if not apiclient._use_unified_worker(options):
         _LOGGER.info(
             'Automatically enabling Dataflow Runner v2 since the '