Add call to Super class in 'google' providers (#7823)

apache · Mar 23, 2020 · 9e5a8e7 · 9e5a8e7
1 parent 74c2a6d
commit 9e5a8e7
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 0 deletions.
diff --git a/airflow/providers/google/ads/hooks/ads.py b/airflow/providers/google/ads/hooks/ads.py
@@ -54,6 +54,7 @@ def __init__(
  google_ads_conn_id: str = "google_ads_default",
  api_version: str = "v2",
  ) -> None:
+ super().__init__()
  self.gcp_conn_id = gcp_conn_id
  self.google_ads_conn_id = google_ads_conn_id
  self.gcp_conn_id = gcp_conn_id

diff --git a/airflow/providers/google/cloud/hooks/base.py b/airflow/providers/google/cloud/hooks/base.py
@@ -155,6 +155,7 @@ class CloudBaseHook(BaseHook):
  """
 
  def __init__(self, gcp_conn_id: str = 'google_cloud_default', delegate_to: Optional[str] = None) -> None:
+ super().__init__()
  self.gcp_conn_id = gcp_conn_id
  self.delegate_to = delegate_to
  self.extras = self.get_connection(self.gcp_conn_id).extra_dejson # type: Dict

diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py
@@ -2067,6 +2067,7 @@ def __init__(self,
  location: Optional[str] = None,
  num_retries: int = 5) -> None:
 
+ super().__init__()
  self.service = service
  self.project_id = project_id
  self.use_legacy_sql = use_legacy_sql

diff --git a/airflow/providers/google/cloud/hooks/cloud_sql.py b/airflow/providers/google/cloud/hooks/cloud_sql.py
@@ -740,6 +740,7 @@ def __init__(
  gcp_conn_id: str = 'google_cloud_default',
  default_gcp_project_id: Optional[str] = None
  ) -> None:
+ super().__init__()
  self.gcp_conn_id = gcp_conn_id
  self.gcp_cloudsql_conn_id = gcp_cloudsql_conn_id
  self.cloudsql_connection = self.get_connection(self.gcp_cloudsql_conn_id)

diff --git a/airflow/providers/google/cloud/hooks/dataflow.py b/airflow/providers/google/cloud/hooks/dataflow.py
@@ -309,6 +309,7 @@ def __init__(
  cmd: List[str],
  on_new_job_id_callback: Optional[Callable[[str], None]] = None
  ) -> None:
+ super().__init__()
  self.log.info("Running command: %s", ' '.join(cmd))
  self.on_new_job_id_callback = on_new_job_id_callback
  self._proc = subprocess.Popen(