Add job failure handler

apache · Jun 20, 2023 · 3bedbb9 · 3bedbb9
1 parent cd746c9
commit 3bedbb9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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: