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