From 5b0c802645e21c5eecb314338bf3c2a2d69206c3 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Mon, 28 Sep 2026 07:11:41 -0400 Subject: [PATCH] Clarify element processing timeout help text Updated help text for element processing timeout to clarify that it applies to fused stages and bundles. --- sdks/python/apache_beam/options/pipeline_options.py | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/sdks/python/apache_beam/options/pipeline_options.py b/sdks/python/apache_beam/options/pipeline_options.py index 6443094fda12..75492344a604 100644 --- a/sdks/python/apache_beam/options/pipeline_options.py +++ b/sdks/python/apache_beam/options/pipeline_options.py @@ -1626,10 +1626,15 @@ def _add_argparse_args(cls, parser): type=int, default=None, help=( - 'The time limit (in minutes) for any PTransform to finish ' - 'processing a single element. If exceeded, the SDK worker ' - 'process self-terminates and processing may be restarted ' - 'by a runner.')) + 'The time limit (in minutes) for any fused stage to finish ' + 'processing a single bundle. A fused stage may include ' + 'multiple consecutive PTransforms. It will also include the ' + 'IO steps used to populate data in the stage (this may be ' + 'a pipeline-level IO or an internal read like reading from a ' + 'Reshuffle or GroupByKey). Exact stage boundaries are determined ' + 'by the pipeline runner. If the timeout is exceeded, the SDK ' + 'worker process self-terminates and processing may be restarted ' + 'by a runner. All in-progress work in this bundle will be lost')) def validate(self, validator): errors = []