diff --git a/sdks/python/apache_beam/options/pipeline_options.py b/sdks/python/apache_beam/options/pipeline_options.py index 5847f9383be58..71cd7958a6e91 100644 --- a/sdks/python/apache_beam/options/pipeline_options.py +++ b/sdks/python/apache_beam/options/pipeline_options.py @@ -414,10 +414,10 @@ def _add_argparse_args(cls, parser): default=False, action='store_true', help='Enable Windmill Service for this Dataflow job. ') - parser.add_argument('--gcp_kms_key', + parser.add_argument('--dataflow_kms_key', default=None, help='Set a Google Cloud KMS key name to be used in ' - 'IO operations.') + 'Dataflow state operations (GBK, Streaming).') def validate(self, validator): errors = []