Merge pull request #31212: Use already-existing and more appropriatel…

…y alarmist experiment in Python
apache · May 8, 2024 · 8328d07 · 8328d07
2 parents 2ad4573 + 0b36f8e
commit 8328d07
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -420,7 +420,7 @@ def run_pipeline(self, pipeline, options, pipeline_proto=None):
            for pcoll in self.proto_pipeline.components.pcollections.values()):
       if (not options.view_as(StandardOptions).streaming and
           not options.view_as(DebugOptions).lookup_experiment(
-              'allow_unbounded_pcollections_in_batch_mode')):
+              'unsafely_attempt_to_process_unbounded_data_in_batch_mode ')):
         _LOGGER.info(
             'Automatically inferring streaming mode '
             'due to unbounded PCollections.')