Merge pull request #28485 [BEAM-28399] Ensure dataflow experiments ar…

…e always set when dataflowflow runner is used.
apache · Sep 16, 2023 · 52abb14 · 52abb14
2 parents 841d7cd + 6870283
commit 52abb14
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -359,6 +359,8 @@ def run_pipeline(self, pipeline, options, pipeline_proto=None):
           'Google Cloud Dataflow runner not available, '
           'please install apache_beam[gcp]')
 
+    _check_and_add_missing_options(options)
+
     # Convert all side inputs into a form acceptable to Dataflow.
     if pipeline:
       pipeline.visit(self.combinefn_visitor())