Use non-deprecated method for on_kill in BigQueryHook (#27547)

apache · Nov 7, 2022 · 199359b · 199359b
1 parent 8c15b0a
commit 199359b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py
@@ -1135,7 +1135,7 @@ def on_kill(self) -> None:
  super().on_kill()
  if self.hook is not None:
  self.log.info("Cancelling running query")
- self.hook.cancel_query()
+ self.hook.cancel_job(self.hook.running_job_id)
 
 
 class BigQueryCreateEmptyTableOperator(BaseOperator):