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 <[email protected]> Authored: Mon Apr 10 14:24:44 2017 +0200 Committer: Ahmet Altay <[email protected]> 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
