This is an automated email from the ASF dual-hosted git repository. goenka 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 5546833 [BEAM-7052] add optional environmentType and environmentConfig properties to python wordcount task new 6bdb739 Merge pull request #8282 from ibzib/loopback 5546833 is described below commit 55468335028f0560abc30c5ed18df63b3e40d07b Author: Kyle Weaver <kcwea...@google.com> AuthorDate: Wed Apr 10 14:32:56 2019 -0700 [BEAM-7052] add optional environmentType and environmentConfig properties to python wordcount task --- sdks/python/build.gradle | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/sdks/python/build.gradle b/sdks/python/build.gradle index f13eb63..8294b8d 100644 --- a/sdks/python/build.gradle +++ b/sdks/python/build.gradle @@ -182,6 +182,12 @@ def portableWordCountTask(name, streaming) { options += ["--environment_cache_millis=10000"] if (project.hasProperty("jobEndpoint")) options += ["--job_endpoint=${project.property('jobEndpoint')}"] + if (project.hasProperty("environmentType")) { + options += ["--environment_type=${project.property('environmentType')}"] + } + if (project.hasProperty("environmentConfig")) { + options += ["--environment_config=${project.property('environmentConfig')}"] + } exec { executable 'sh' args '-c', ". ${project.ext.envdir}/bin/activate && python -m apache_beam.examples.wordcount ${options.join(' ')}"