From 0b36f8e23fc0f7de202ed941a025ddf75ae9930b Mon Sep 17 00:00:00 2001 From: Kenneth Knowles Date: Tue, 7 May 2024 15:29:02 -0400 Subject: [PATCH] Use already-existing and more appropriately alarmist experiment in Python --- sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py index 7d4be174206c..b8837ce13c90 100644 --- 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.')