This is an automated email from the ASF dual-hosted git repository. pabloem 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 09c556f [BEAM-5959] Adding the gcp_kms_key option to Python SDK. (#7696) 09c556f is described below commit 09c556f8bab849ed033e65987a3f2825ff2734a2 Author: Pablo <pabl...@users.noreply.github.com> AuthorDate: Fri Feb 1 11:13:44 2019 -0800 [BEAM-5959] Adding the gcp_kms_key option to Python SDK. (#7696) * Adding the gcp_kms_key option to Python SDK. * fix typo --- sdks/python/apache_beam/options/pipeline_options.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sdks/python/apache_beam/options/pipeline_options.py b/sdks/python/apache_beam/options/pipeline_options.py index a7c74b4..c1e94a1 100644 --- a/sdks/python/apache_beam/options/pipeline_options.py +++ b/sdks/python/apache_beam/options/pipeline_options.py @@ -410,6 +410,10 @@ class GoogleCloudOptions(PipelineOptions): 'Experimental. ' 'See https://cloud.google.com/dataflow/pipelines/' 'updating-a-pipeline') + parser.add_argument('--gcp_kms_key', + default=None, + help='Set a Google Cloud KMS key name to be used in ' + 'IO operations.') def validate(self, validator): errors = []