replace deprecated call

ying-w · Apr 22, 2023 · 5dabb5b · 5dabb5b
1 parent e8c7f72
commit 5dabb5b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py
@@ -2718,7 +2718,7 @@ def execute(self, operation: str, parameters: dict | None = None) -> None:
         """
         sql = _bind_parameters(operation, parameters) if parameters else operation
         self.flush_results()
-        self.job_id = self.hook.run_query(sql)
+        self.job_id = self.hook.insert_job(sql)
 
         query_results = self._get_query_result()
         if "schema" in query_results: