avoid deprecation warnings in BigQuery transfer operators (#20502)

apache · Dec 28, 2021 · 7d4d38b · 7d4d38b
1 parent b5d520c
commit 7d4d38b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/airflow/providers/google/cloud/transfers/bigquery_to_gcs.py b/airflow/providers/google/cloud/transfers/bigquery_to_gcs.py
@@ -132,7 +132,7 @@ def execute(self, context):
  self.destination_cloud_storage_uris,
  )
  hook = BigQueryHook(
- bigquery_conn_id=self.gcp_conn_id,
+ gcp_conn_id=self.gcp_conn_id,
  delegate_to=self.delegate_to,
  location=self.location,
  impersonation_chain=self.impersonation_chain,

diff --git a/airflow/providers/google/cloud/transfers/bigquery_to_mssql.py b/airflow/providers/google/cloud/transfers/bigquery_to_mssql.py
@@ -116,7 +116,7 @@ def __init__(
  def _bq_get_data(self):
 
  hook = BigQueryHook(
- bigquery_conn_id=self.gcp_conn_id,
+ gcp_conn_id=self.gcp_conn_id,
  delegate_to=self.delegate_to,
  location=self.location,
  impersonation_chain=self.impersonation_chain,

diff --git a/airflow/providers/google/cloud/transfers/bigquery_to_mysql.py b/airflow/providers/google/cloud/transfers/bigquery_to_mysql.py
@@ -123,7 +123,7 @@ def _bq_get_data(self):
  self.log.info('Dataset: %s ; Table: %s', self.dataset_id, self.table_id)
 
  hook = BigQueryHook(
- bigquery_conn_id=self.gcp_conn_id,
+ gcp_conn_id=self.gcp_conn_id,
  delegate_to=self.delegate_to,
  location=self.location,
  impersonation_chain=self.impersonation_chain,