Repository: incubator-airflow Updated Branches: refs/heads/master 062354de0 -> edf55cd21
[AIRFLOW-712] Fix AIRFLOW-667 to use proper HTTP error properties Closes #1955 from criccomini/AIRFLOW-712 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/edf55cd2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/edf55cd2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/edf55cd2 Branch: refs/heads/master Commit: edf55cd21e1d220c1d19031d7f1b8e666aad770c Parents: 062354d Author: Chris Riccomini <[email protected]> Authored: Thu Dec 22 22:31:50 2016 +0100 Committer: Alex Van Boxel <[email protected]> Committed: Thu Dec 22 22:32:06 2016 +0100 ---------------------------------------------------------------------- airflow/contrib/hooks/bigquery_hook.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/edf55cd2/airflow/contrib/hooks/bigquery_hook.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/hooks/bigquery_hook.py b/airflow/contrib/hooks/bigquery_hook.py index 1a33a0a..450ee7a 100644 --- a/airflow/contrib/hooks/bigquery_hook.py +++ b/airflow/contrib/hooks/bigquery_hook.py @@ -490,12 +490,12 @@ class BigQueryBaseCursor(object): time.sleep(5) except HttpError as err: - if err.code in [500, 503]: - logging.info('%s: Retryable error, waiting for job to complete: %s', err.code, job_id) + if err.resp.status in [500, 503]: + logging.info('%s: Retryable error, waiting for job to complete: %s', err.resp.status, job_id) time.sleep(5) else: raise Exception( - 'BigQuery job status check faild. Final error was: %s', err.code) + 'BigQuery job status check failed. Final error was: %s', err.resp.status) return job_id
