You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/07/13 03:06:40 UTC
[28/50] [abbrv] beam git commit: [BEAM-2570] Fix breakage after
cloud-bigquery updated
[BEAM-2570] Fix breakage after cloud-bigquery updated
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eee0c9c3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eee0c9c3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/eee0c9c3
Branch: refs/heads/DSL_SQL
Commit: eee0c9c38ea33d123c9be6ee81fd8f31bcb44d14
Parents: b1313ff
Author: Mark Liu <ma...@google.com>
Authored: Fri Jul 7 15:20:12 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
Committed: Wed Jul 12 20:01:01 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py | 6 +++---
sdks/python/apache_beam/io/gcp/tests/bigquery_matcher_test.py | 2 +-
sdks/python/setup.py | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/eee0c9c3/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py b/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
index 844cbc5..d6f0e97 100644
--- a/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
+++ b/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
@@ -92,9 +92,9 @@ class BigqueryMatcher(BaseMatcher):
page_token = None
results = []
while True:
- rows, _, page_token = query.fetch_data(page_token=page_token)
- results.extend(rows)
- if not page_token:
+ for row in query.fetch_data(page_token=page_token):
+ results.append(row)
+ if results:
break
return results
http://git-wip-us.apache.org/repos/asf/beam/blob/eee0c9c3/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher_test.py b/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher_test.py
index f12293e..5b72285 100644
--- a/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher_test.py
+++ b/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher_test.py
@@ -53,7 +53,7 @@ class BigqueryMatcherTest(unittest.TestCase):
matcher = bq_verifier.BigqueryMatcher(
'mock_project',
'mock_query',
- 'da39a3ee5e6b4b0d3255bfef95601890afd80709')
+ '59f9d6bdee30d67ea73b8aded121c3a0280f9cd8')
hc_assert_that(self._mock_result, matcher)
@patch.object(bigquery, 'Client')
http://git-wip-us.apache.org/repos/asf/beam/blob/eee0c9c3/sdks/python/setup.py
----------------------------------------------------------------------
diff --git a/sdks/python/setup.py b/sdks/python/setup.py
index 8a0c9ae..da82466 100644
--- a/sdks/python/setup.py
+++ b/sdks/python/setup.py
@@ -122,7 +122,7 @@ GCP_REQUIREMENTS = [
'googledatastore==7.0.1',
'google-cloud-pubsub==0.26.0',
# GCP packages required by tests
- 'google-cloud-bigquery>=0.23.0,<0.26.0',
+ 'google-cloud-bigquery==0.25.0',
]