From 199359bb3886699904ca075de7bd5fdfe5105c5f Mon Sep 17 00:00:00 2001 From: Daniel Standish <15932138+dstandish@users.noreply.github.com> Date: Mon, 7 Nov 2022 11:59:26 -0800 Subject: [PATCH] Use non-deprecated method for on_kill in BigQueryHook (#27547) --- airflow/providers/google/cloud/operators/bigquery.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index 9dd481c093548..b167038388c5b 100644 --- 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):