This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 306e7d128d8 Clarify element processing timeout help text (#40312)
306e7d128d8 is described below
commit 306e7d128d833f46045e67fb85299f5db84bec00
Author: Danny McCormick <[email protected]>
AuthorDate: Tue Sep 29 13:08:21 2026 +0000
Clarify element processing timeout help text (#40312)
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 6443094fda1..75492344a60 100644
--- a/sdks/python/apache_beam/options/pipeline_options.py
+++ b/sdks/python/apache_beam/options/pipeline_options.py
@@ -1626,10 +1626,15 @@ class WorkerOptions(PipelineOptions):
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 = []
