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(' ')}"

Reply via email to