From a7e6a49822d00d825e004349201451bff707e32a Mon Sep 17 00:00:00 2001 From: Wei Lee Date: Thu, 6 Jun 2024 12:28:16 +0900 Subject: [PATCH] feat(providers/google): add default gcp_conn_id to GoogleBaseAsyncHook --- airflow/providers/google/common/hooks/base_google.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/airflow/providers/google/common/hooks/base_google.py b/airflow/providers/google/common/hooks/base_google.py index 0de39330a95a4..04c86f378c112 100644 --- a/airflow/providers/google/common/hooks/base_google.py +++ b/airflow/providers/google/common/hooks/base_google.py @@ -731,7 +731,11 @@ class GoogleBaseAsyncHook(BaseHook): sync_hook_class: Any = None - def __init__(self, **kwargs: Any): + def __init__(self, **kwargs: Any) -> None: + # add default value to gcp_conn_id + if "gcp_conn_id" not in kwargs: + kwargs["gcp_conn_id"] = "google_cloud_default" + self._hook_kwargs = kwargs self._sync_hook = None