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 = []