[BEAM-28399] Ensure dataflow experiments are always set when dataflow…

… runner is used.
apache · Sep 15, 2023 · 6870283 · 6870283
1 parent 220cae7
commit 6870283
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())