[beam] branch master updated: [BEAM-6621] Basic Bigquery IO tests on Python 3 PostCommit

[altay]

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 7f6d201  [BEAM-6621] Basic Bigquery IO tests on Python 3 PostCommit
     new 381ab55  Merge pull request #7782 from markflyhigh/py3-bq-it
7f6d201 is described below

commit 7f6d201fe6b139f2ddb4fa59bbedc2d14e7a7c98
Author: Mark Liu <mark...@google.com>
AuthorDate: Thu Feb 7 15:45:59 2019 -0800

    [BEAM-6621] Basic Bigquery IO tests on Python 3 PostCommit
---
 sdks/python/precommit/dataflow/py3/build.gradle | 6 +++++-
 sdks/python/precommit/direct/py3/build.gradle   | 6 +++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/sdks/python/precommit/dataflow/py3/build.gradle 
b/sdks/python/precommit/dataflow/py3/build.gradle
index b73e55d..9d343d5 100644
--- a/sdks/python/precommit/dataflow/py3/build.gradle
+++ b/sdks/python/precommit/dataflow/py3/build.gradle
@@ -26,8 +26,12 @@ def runScriptsDir = "${project.rootDir}/sdks/python/scripts"
 
 task preCommitIT(dependsOn: ['sdist', 'installGcpTest']) {
   doLast {
+    def tests = [
+        "apache_beam.examples.wordcount_it_test:WordCountIT.test_wordcount_it",
+        
"apache_beam.examples.cookbook.bigquery_tornadoes_it_test:BigqueryTornadoesIT.test_bigquery_tornadoes_it",
+    ]
     def testOpts = [
-        
"--tests=apache_beam.examples.wordcount_it_test:WordCountIT.test_wordcount_it",
+        "--tests=${tests.join(',')}",
         "--nocapture",    // Print stdout instantly
     ]
     def cmdArgs = project.mapToArgString(["test_opts": testOpts])
diff --git a/sdks/python/precommit/direct/py3/build.gradle 
b/sdks/python/precommit/direct/py3/build.gradle
index d28ce7b..9b7f679 100644
--- a/sdks/python/precommit/direct/py3/build.gradle
+++ b/sdks/python/precommit/direct/py3/build.gradle
@@ -27,8 +27,12 @@ def runScriptsDir = "${project.rootDir}/sdks/python/scripts"
 task preCommitIT(dependsOn: ['sdist', 'installGcpTest']) {
   // Run IT tests with TestDirectRunner in batch in Python 3.
   doLast {
+    def batchTests = [
+        "apache_beam.examples.wordcount_it_test:WordCountIT.test_wordcount_it",
+        
"apache_beam.examples.cookbook.bigquery_tornadoes_it_test:BigqueryTornadoesIT.test_bigquery_tornadoes_it",
+    ]
     def testOpts = [
-        
"--tests=apache_beam.examples.wordcount_it_test:WordCountIT.test_wordcount_it",
+        "--tests=${batchTests.join(',')}",
         "--nocapture",    // Print stdout instantly
     ]
     def argMap = ["runner": "TestDirectRunner",