From ac4251aa0e973e3b2bdcf640afcb831744cf8777 Mon Sep 17 00:00:00 2001 From: Jan Tattermusch <jtattermusch@google.com> Date: Fri, 15 Apr 2016 14:44:59 -0700 Subject: [PATCH] fix error handling in big_query_utils.insert_rows --- tools/gcp/utils/big_query_utils.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tools/gcp/utils/big_query_utils.py b/tools/gcp/utils/big_query_utils.py index 913afd059e..9dbc69c5d6 100755 --- a/tools/gcp/utils/big_query_utils.py +++ b/tools/gcp/utils/big_query_utils.py @@ -119,9 +119,13 @@ def insert_rows(big_query, project_id, dataset_id, table_id, rows_list): tableId=table_id, body=body) res = insert_req.execute(num_retries=NUM_RETRIES) + if res.get('insertErrors', None): + print 'Error inserting rows! Response: %s' % res + is_success = False except HttpError as http_error: - print 'Error in inserting rows in the table %s' % table_id + print 'Error inserting rows to the table %s' % table_id is_success = False + return is_success -- GitLab