beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [1/2] beam git commit: better log message for bigquery temp tables
Date Mon, 10 Apr 2017 16:30:26 GMT
Repository: beam
Updated Branches:
  refs/heads/master 713701ddc -> e4c3ecf4a


better log message for bigquery temp tables


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6b2659cf
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6b2659cf
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6b2659cf

Branch: refs/heads/master
Commit: 6b2659cff9a7cc3283a8172ef87f589e887cf6f2
Parents: 713701d
Author: Uwe Jugel <uwe.jugel@lovoo.com>
Authored: Mon Apr 10 14:24:44 2017 +0200
Committer: Ahmet Altay <altay@google.com>
Committed: Mon Apr 10 09:30:13 2017 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/io/gcp/bigquery.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/6b2659cf/sdks/python/apache_beam/io/gcp/bigquery.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/gcp/bigquery.py b/sdks/python/apache_beam/io/gcp/bigquery.py
index a917d51..788c069 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery.py
@@ -839,7 +839,7 @@ class BigQueryWrapper(object):
       self.client.datasets.Delete(request)
     except HttpError as exn:
       if exn.status_code == 404:
-        logging.warning('Dataaset %s:%s does not exist', project_id,
+        logging.warning('Dataset %s:%s does not exist', project_id,
                         dataset_id)
         return
       else:
@@ -861,7 +861,9 @@ class BigQueryWrapper(object):
             % (project_id, dataset_id))
     except HttpError as exn:
       if exn.status_code == 404:
-        logging.warning('Dataset does not exist so we will create it')
+        logging.warning(
+            'Dataset %s:%s does not exist so we will create it as temporary',
+            project_id, dataset_id)
         self.get_or_create_dataset(project_id, dataset_id)
       else:
         raise


Mime
View raw message