Repository: incubator-airflow Updated Branches: refs/heads/master e36f9a750 -> 0235d59d0
[AIRFLOW-577] Output BigQuery job for improved debugging Closes #1838 from waltherg/fix/bq_error_message Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/0235d59d Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/0235d59d Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/0235d59d Branch: refs/heads/master Commit: 0235d59d052524d0d773e07b13867691223f9904 Parents: e36f9a7 Author: Georg Walther <georgwalt...@gmail.com> Authored: Mon Oct 17 08:51:56 2016 -0700 Committer: Chris Riccomini <chr...@wepay.com> Committed: Mon Oct 17 08:51:56 2016 -0700 ---------------------------------------------------------------------- airflow/contrib/hooks/bigquery_hook.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/0235d59d/airflow/contrib/hooks/bigquery_hook.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/hooks/bigquery_hook.py b/airflow/contrib/hooks/bigquery_hook.py index c5b57a9..e8528ac 100644 --- a/airflow/contrib/hooks/bigquery_hook.py +++ b/airflow/contrib/hooks/bigquery_hook.py @@ -435,7 +435,10 @@ class BigQueryBaseCursor(object): # Check if job had errors. if 'errorResult' in job['status']: raise Exception( - 'BigQuery job failed. Final error was: %s', job['status']['errorResult']) + 'BigQuery job failed. Final error was: {}. The job was: {}'.format( + job['status']['errorResult'], job + ) + ) return job_id
