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 <[email protected]>
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(' ')}"