Update SDKs for google provider package

airflow/providers/apache/beam/provider.yaml

@@ -43,7 +43,7 @@ versions:
 
 dependencies:
   - apache-airflow>=2.4.0
-  - apache-beam>=2.33.0
+  - apache-beam>=2.47.0
 
 integrations:
   - integration-name: Apache Beam

airflow/providers/google/ads/hooks/ads.py

@@ -21,26 +21,18 @@
 from tempfile import NamedTemporaryFile
 from typing import IO, Any
 
+from google.ads.googleads.client import GoogleAdsClient
+from google.ads.googleads.errors import GoogleAdsException
+from google.ads.googleads.v12.services.services.customer_service import CustomerServiceClient
+from google.ads.googleads.v12.services.services.google_ads_service import GoogleAdsServiceClient
+from google.ads.googleads.v12.services.types.google_ads_service import GoogleAdsRow
+from google.api_core.page_iterator import GRPCIterator
 from google.auth.exceptions import GoogleAuthError
 
 from airflow import AirflowException
 from airflow.compat.functools import cached_property
 from airflow.hooks.base import BaseHook
 from airflow.providers.google.common.hooks.base_google import get_field
-from airflow.providers.google_vendor.googleads.client import GoogleAdsClient
-from airflow.providers.google_vendor.googleads.errors import GoogleAdsException
-from airflow.providers.google_vendor.googleads.v12.services.services.customer_service import (
-    CustomerServiceClient,
-)
-from airflow.providers.google_vendor.googleads.v12.services.services.google_ads_service import (
-    GoogleAdsServiceClient,
-)
-from airflow.providers.google_vendor.googleads.v12.services.services.google_ads_service.pagers import (
-    SearchPager,
-)
-from airflow.providers.google_vendor.googleads.v12.services.types.google_ads_service import (
-    GoogleAdsRow,
-)
 
 
 class GoogleAdsHook(BaseHook):
@@ -238,7 +230,7 @@ def _search(
 
         return self._extract_rows(iterators)
 
-    def _extract_rows(self, iterators: list[SearchPager]) -> list[GoogleAdsRow]:
+    def _extract_rows(self, iterators: list[GRPCIterator]) -> list[GoogleAdsRow]:
         """
         Convert Google Page Iterator (GRPCIterator) objects to Google Ads Rows
 

airflow/providers/google/cloud/_internal_client/secret_manager_client.py

@@ -71,7 +71,7 @@ def get_secret(self, secret_id: str, project_id: str, secret_version: str = "lat
         """
         name = self.client.secret_version_path(project_id, secret_id, secret_version)
         try:
-            response = self.client.access_secret_version(name)
+            response = self.client.access_secret_version(request={"name": name})
             value = response.payload.data.decode("UTF-8")
             return value
         except NotFound:

airflow/providers/google/cloud/hooks/automl.py

@@ -48,6 +48,7 @@
 )
 from google.protobuf.field_mask_pb2 import FieldMask
 
+from airflow import AirflowException
 from airflow.compat.functools import cached_property
 from airflow.providers.google.common.consts import CLIENT_INFO
 from airflow.providers.google.common.hooks.base_google import PROVIDE_PROJECT_ID, GoogleBaseHook
@@ -93,6 +94,14 @@ def get_conn(self) -> AutoMlClient:
             self._client = AutoMlClient(credentials=self.get_credentials(), client_info=CLIENT_INFO)
         return self._client
 
+    def wait_for_operation(self, operation: Operation, timeout: float | None = None):
+        """Waits for long-lasting operation to complete."""
+        try:
+            return operation.result(timeout=timeout)
+        except Exception:
+            error = operation.exception(timeout=timeout)
+            raise AirflowException(error)
+
     @cached_property
     def prediction_client(self) -> PredictionServiceClient:
         """