Log BigQuery job id in insert method of BigQueryHook (#12056)

apache · Nov 3, 2020 · 45ae145 · 45ae145
1 parent 57768e6
commit 45ae145
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py
@@ -1500,6 +1500,7 @@ def insert_job(
         if not job:
             raise AirflowException(f"Unknown job type. Supported types: {supported_jobs.keys()}")
         job = job.from_api_repr(job_data, client)
+        self.log.info("Inserting job %s", job.job_id)
         # Start the job and wait for it to complete and get the result.
         job.result()
         return job