[beam] branch master updated: [BEAM-7814] Fix BigqueryMatcher._matches when called more than once.

[pabloem]

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 90d6ba1  [BEAM-7814] Fix BigqueryMatcher._matches when called more 
than once.
     new 31c8e87  Merge pull request #9224 from udim/bq-matcher-fix
90d6ba1 is described below

commit 90d6ba125f2fcc78fad42ca2c05fb1b1ffea4f26
Author: Udi Meiri <eh...@google.com>
AuthorDate: Thu Aug 1 14:22:40 2019 -0700

    [BEAM-7814] Fix BigqueryMatcher._matches when called more than once.
---
 sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 2180b86..c3394a1 100644
--- a/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
+++ b/sdks/python/apache_beam/io/gcp/tests/bigquery_matcher.py
@@ -85,9 +85,9 @@ class BigqueryMatcher(BaseMatcher):
       response = self._query_with_retry()
       logging.info('Read from given query (%s), total rows %d',
                    self.query, len(response))
+      self.checksum = compute_hash(response)
+      logging.info('Generate checksum: %s', self.checksum)
 
-    self.checksum = compute_hash(response)
-    logging.info('Generate checksum: %s', self.checksum)
     return self.checksum == self.expected_checksum
 
   @retry.with_exponential_backoff(