[beam] branch master updated: Allow setting dataflow_endpoint for Python ITs

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

altay 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 d3e040f  Allow setting dataflow_endpoint for Python ITs
     new cf2f35c  Merge pull request #7894 from udim/kms-proto
d3e040f is described below

commit d3e040fd430ef909ce3bddd0054296667fe6e697
Author: Udi Meiri <eh...@google.com>
AuthorDate: Tue Feb 19 15:08:08 2019 -0800

    Allow setting dataflow_endpoint for Python ITs
---
 sdks/python/scripts/run_integration_test.sh | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/sdks/python/scripts/run_integration_test.sh b/sdks/python/scripts/run_integration_test.sh
index 33e8199..5fa066c 100755
--- a/sdks/python/scripts/run_integration_test.sh
+++ b/sdks/python/scripts/run_integration_test.sh
@@ -126,6 +126,11 @@ case $key in
         shift # past argument
         shift # past value
         ;;
+    --dataflow_endpoint)
+        DATAFLOW_ENDPOINT="$2"
+        shift # past argument
+        shift # past value
+        ;;
     --pipeline_opts)
         PIPELINE_OPTS="$2"
         shift # past argument
@@ -206,6 +211,10 @@ if [[ -z $PIPELINE_OPTS ]]; then
     )
   fi
 
+  if [[ ! -z "$DATAFLOW_ENDPOINT" ]]; then
+    opts+=("--dataflow_endpoint=$DATAFLOW_ENDPOINT")
+  fi
+
   PIPELINE_OPTS=$(IFS=" " ; echo "${opts[*]}")
 
 fi
@@ -214,6 +223,7 @@ fi
 # Run tests and validate that jobs finish successfully.
 
 echo ">>> RUNNING integration tests with pipeline options: $PIPELINE_OPTS"
+echo ">>>   test options: $TEST_OPTS"
 python setup.py nosetests \
   --test-pipeline-options="$PIPELINE_OPTS" \
   $TEST_OPTS