From 3bedbb9f2680d49cceb11e116f68d089ae8eacd5 Mon Sep 17 00:00:00 2001 From: Phani Kumar Date: Tue, 20 Jun 2023 21:23:32 +0530 Subject: [PATCH] Add job failure handler --- airflow/providers/google/cloud/operators/bigquery.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index 057853d5d826f..b53e06d25f429 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -380,6 +380,7 @@ def execute(self, context: Context) -> None: # type: ignore[override] method_name="execute_complete", ) self._handle_job_error(job) + self.log.info("Current state of job %s is %s", job.job_id, job.state) @staticmethod def _handle_job_error(job: BigQueryJob | UnknownJob) -> None: