This is an automated email from the ASF dual-hosted git repository.
pabloem 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 608a861 Adding logging and adding one more retry
new 29daca2 Merge pull request #9084 from pabloem/bqlggn
608a861 is described below
commit 608a86182e82ac5e1a1ad9b97c6e821e1bb080c0
Author: pabloem <pabl...@apache.org>
AuthorDate: Tue Jul 16 16:53:48 2019 -0700
Adding logging and adding one more retry
---
sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
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 216963a..de70dc3 100644
--- a/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
+++ b/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
@@ -40,7 +40,7 @@ except ImportError:
bigquery = None
# pylint: enable=wrong-import-order, wrong-import-position
-MAX_RETRIES = 4
+MAX_RETRIES = 5
def retry_on_http_and_value_error(exception):
@@ -140,6 +140,7 @@ class BigqueryFullResultMatcher(BaseMatcher):
response = self._get_query_result(bigquery_client)
logging.info('Read from given query (%s), total rows %d',
self.query, len(response))
+ logging.info('Response from BigQuery is %r', response)
self.actual_data = response
@@ -154,7 +155,9 @@ class BigqueryFullResultMatcher(BaseMatcher):
retry_filter=retry_on_http_and_value_error)
def _query_with_retry(self, bigquery_client):
"""Run Bigquery query with retry if got error http response"""
+ logging.info('Attempting to perform query %s to BQ', self.query)
query_job = bigquery_client.query(self.query)
+ logging.info('Result of query is: %r', query_job)
return [row.values() for row in query_job]
def describe_to(self, description):
