chore: use gapic-generator-python 0.53.4 (#94)

* chore: use gapic-generator-python 0.53.4

docs: list oneofs in docstring
fix(deps): require google-api-core >= 1.28.0
fix(deps): drop packaging dependency

committer: busunkim96@
PiperOrigin-RevId: 406468269

Source-Link: googleapis/googleapis@83d81b0

Source-Link: googleapis/googleapis-gen@2ff001f
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMmZmMDAxZmJhY2I5ZTc3ZTcxZDczNGRlNWY5NTVjMDVmZGFlODUyNiJ9

* 🦉 Updates from OwlBot

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* fix(deps): require google-api-core >= 1.28.0

* fix(deps): drop packaging dependency

* run owlbot-cli locally

* add replacements in owlbot.py to work around generator bug

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
Co-authored-by: Anthonios Partheniou <partheniou@google.com>

packages/google-cloud-gke-hub/.github/.OwlBot.yaml

@@ -21,7 +21,7 @@ deep-remove-regex:
 deep-preserve-regex:
   - /owl-bot-staging/v1alpha
   - /owl-bot-staging/v1alpha2
-  - /owl-bot-staging/v1beta
+  - /owl-bot-staging/v1beta/
 
 deep-copy-regex:
   - source: /google/cloud/gkehub/(v.*)/.*-py/(.*)

packages/google-cloud-gke-hub/google/cloud/gkehub_v1/configmanagement_v1/types/configmanagement.py

@@ -181,6 +181,8 @@ class GitConfig(proto.Message):
 class PolicyController(proto.Message):
     r"""Configuration for Policy Controller
 
+    .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
+
     Attributes:
         enabled (bool):
             Enables the installation of Policy
@@ -189,10 +191,14 @@ class PolicyController(proto.Message):
         template_library_installed (bool):
             Installs the default template library along
             with Policy Controller.
+
+            This field is a member of `oneof`_ ``_template_library_installed``.
         audit_interval_seconds (int):
             Sets the interval for Policy Controller Audit
             Scans (in seconds). When set to 0, this disables
             audit functionality altogether.
+
+            This field is a member of `oneof`_ ``_audit_interval_seconds``.
         exemptable_namespaces (Sequence[str]):
             The set of namespaces that are excluded from
             Policy Controller checks. Namespaces do not need

packages/google-cloud-gke-hub/google/cloud/gkehub_v1/services/gke_hub/async_client.py

@@ -19,13 +19,15 @@
 from typing import Dict, Sequence, Tuple, Type, Union
 import pkg_resources
 
-import google.api_core.client_options as ClientOptions  # type: ignore
+from google.api_core.client_options import ClientOptions  # type: ignore
 from google.api_core import exceptions as core_exceptions  # type: ignore
 from google.api_core import gapic_v1  # type: ignore
 from google.api_core import retry as retries  # type: ignore
 from google.auth import credentials as ga_credentials  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
+OptionalRetry = Union[retries.Retry, object]
+
 from google.api_core import operation  # type: ignore
 from google.api_core import operation_async  # type: ignore
 from google.cloud.gkehub_v1.services.gke_hub import pagers
@@ -176,17 +178,17 @@ def __init__(
 
     async def list_memberships(
         self,
-        request: service.ListMembershipsRequest = None,
+        request: Union[service.ListMembershipsRequest, dict] = None,
         *,
         parent: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pagers.ListMembershipsAsyncPager:
         r"""Lists Memberships in a given project and location.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.ListMembershipsRequest`):
+            request (Union[google.cloud.gkehub_v1.types.ListMembershipsRequest, dict]):
                 The request object. Request message for
                 `GkeHub.ListMemberships` method.
             parent (:class:`str`):
@@ -256,17 +258,17 @@ async def list_memberships(
 
     async def list_features(
         self,
-        request: service.ListFeaturesRequest = None,
+        request: Union[service.ListFeaturesRequest, dict] = None,
         *,
         parent: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pagers.ListFeaturesAsyncPager:
         r"""Lists Features in a given project and location.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.ListFeaturesRequest`):
+            request (Union[google.cloud.gkehub_v1.types.ListFeaturesRequest, dict]):
                 The request object. Request message for
                 `GkeHub.ListFeatures` method.
             parent (:class:`str`):
@@ -336,17 +338,17 @@ async def list_features(
 
     async def get_membership(
         self,
-        request: service.GetMembershipRequest = None,
+        request: Union[service.GetMembershipRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> membership.Membership:
         r"""Gets the details of a Membership.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.GetMembershipRequest`):
+            request (Union[google.cloud.gkehub_v1.types.GetMembershipRequest, dict]):
                 The request object. Request message for
                 `GkeHub.GetMembership` method.
             name (:class:`str`):
@@ -407,17 +409,17 @@ async def get_membership(
 
     async def get_feature(
         self,
-        request: service.GetFeatureRequest = None,
+        request: Union[service.GetFeatureRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> feature.Feature:
         r"""Gets details of a single Feature.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.GetFeatureRequest`):
+            request (Union[google.cloud.gkehub_v1.types.GetFeatureRequest, dict]):
                 The request object. Request message for
                 `GkeHub.GetFeature` method.
             name (:class:`str`):
@@ -478,12 +480,12 @@ async def get_feature(
 
     async def create_membership(
         self,
-        request: service.CreateMembershipRequest = None,
+        request: Union[service.CreateMembershipRequest, dict] = None,
         *,
         parent: str = None,
         resource: membership.Membership = None,
         membership_id: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation_async.AsyncOperation:
@@ -494,7 +496,7 @@ async def create_membership(
         https://cloud.google.com/anthos/multicluster-management/connect/registering-a-cluster.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.CreateMembershipRequest`):
+            request (Union[google.cloud.gkehub_v1.types.CreateMembershipRequest, dict]):
                 The request object. Request message for the
                 `GkeHub.CreateMembership` method.
             parent (:class:`str`):
@@ -593,19 +595,19 @@ async def create_membership(
 
     async def create_feature(
         self,
-        request: service.CreateFeatureRequest = None,
+        request: Union[service.CreateFeatureRequest, dict] = None,
         *,
         parent: str = None,
         resource: feature.Feature = None,
         feature_id: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation_async.AsyncOperation:
         r"""Adds a new Feature.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.CreateFeatureRequest`):
+            request (Union[google.cloud.gkehub_v1.types.CreateFeatureRequest, dict]):
                 The request object. Request message for the
                 `GkeHub.CreateFeature` method.
             parent (:class:`str`):
@@ -692,10 +694,10 @@ async def create_feature(
 
     async def delete_membership(
         self,
-        request: service.DeleteMembershipRequest = None,
+        request: Union[service.DeleteMembershipRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation_async.AsyncOperation:
@@ -707,7 +709,7 @@ async def delete_membership(
         https://cloud.google.com/anthos/multicluster-management/connect/unregistering-a-cluster.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.DeleteMembershipRequest`):
+            request (Union[google.cloud.gkehub_v1.types.DeleteMembershipRequest, dict]):
                 The request object. Request message for
                 `GkeHub.DeleteMembership` method.
             name (:class:`str`):
@@ -789,17 +791,17 @@ async def delete_membership(
 
     async def delete_feature(
         self,
-        request: service.DeleteFeatureRequest = None,
+        request: Union[service.DeleteFeatureRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation_async.AsyncOperation:
         r"""Removes a Feature.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.DeleteFeatureRequest`):
+            request (Union[google.cloud.gkehub_v1.types.DeleteFeatureRequest, dict]):
                 The request object. Request message for
                 `GkeHub.DeleteFeature` method.
             name (:class:`str`):
@@ -881,19 +883,19 @@ async def delete_feature(
 
     async def update_membership(
         self,
-        request: service.UpdateMembershipRequest = None,
+        request: Union[service.UpdateMembershipRequest, dict] = None,
         *,
         name: str = None,
         resource: membership.Membership = None,
         update_mask: field_mask_pb2.FieldMask = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation_async.AsyncOperation:
         r"""Updates an existing Membership.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.UpdateMembershipRequest`):
+            request (Union[google.cloud.gkehub_v1.types.UpdateMembershipRequest, dict]):
                 The request object. Request message for
                 `GkeHub.UpdateMembership` method.
             name (:class:`str`):
@@ -988,19 +990,19 @@ async def update_membership(
 
     async def update_feature(
         self,
-        request: service.UpdateFeatureRequest = None,
+        request: Union[service.UpdateFeatureRequest, dict] = None,
         *,
         name: str = None,
         resource: feature.Feature = None,
         update_mask: field_mask_pb2.FieldMask = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation_async.AsyncOperation:
         r"""Updates an existing Feature.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.UpdateFeatureRequest`):
+            request (Union[google.cloud.gkehub_v1.types.UpdateFeatureRequest, dict]):
                 The request object. Request message for
                 `GkeHub.UpdateFeature` method.
             name (:class:`str`):
@@ -1095,9 +1097,9 @@ async def update_feature(
 
     async def generate_connect_manifest(
         self,
-        request: service.GenerateConnectManifestRequest = None,
+        request: Union[service.GenerateConnectManifestRequest, dict] = None,
         *,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> service.GenerateConnectManifestResponse:
@@ -1107,7 +1109,7 @@ async def generate_connect_manifest(
         Most clients should not need to call this method directly.
 
         Args:
-            request (:class:`google.cloud.gkehub_v1.types.GenerateConnectManifestRequest`):
+            request (Union[google.cloud.gkehub_v1.types.GenerateConnectManifestRequest, dict]):
                 The request object. Request message for
                 `GkeHub.GenerateConnectManifest` method.
                 .

packages/google-cloud-gke-hub/google/cloud/gkehub_v1/services/gke_hub/client.py

@@ -30,6 +30,8 @@
 from google.auth.exceptions import MutualTLSChannelError  # type: ignore
 from google.oauth2 import service_account  # type: ignore
 
+OptionalRetry = Union[retries.Retry, object]
+
 from google.api_core import operation  # type: ignore
 from google.api_core import operation_async  # type: ignore
 from google.cloud.gkehub_v1.services.gke_hub import pagers
@@ -387,7 +389,7 @@ def list_memberships(
         request: Union[service.ListMembershipsRequest, dict] = None,
         *,
         parent: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pagers.ListMembershipsPager:
@@ -467,7 +469,7 @@ def list_features(
         request: Union[service.ListFeaturesRequest, dict] = None,
         *,
         parent: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> pagers.ListFeaturesPager:
@@ -547,7 +549,7 @@ def get_membership(
         request: Union[service.GetMembershipRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> membership.Membership:
@@ -618,7 +620,7 @@ def get_feature(
         request: Union[service.GetFeatureRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> feature.Feature:
@@ -691,7 +693,7 @@ def create_membership(
         parent: str = None,
         resource: membership.Membership = None,
         membership_id: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation.Operation:
@@ -806,7 +808,7 @@ def create_feature(
         parent: str = None,
         resource: feature.Feature = None,
         feature_id: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation.Operation:
@@ -903,7 +905,7 @@ def delete_membership(
         request: Union[service.DeleteMembershipRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation.Operation:
@@ -1000,7 +1002,7 @@ def delete_feature(
         request: Union[service.DeleteFeatureRequest, dict] = None,
         *,
         name: str = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation.Operation:
@@ -1094,7 +1096,7 @@ def update_membership(
         name: str = None,
         resource: membership.Membership = None,
         update_mask: field_mask_pb2.FieldMask = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation.Operation:
@@ -1201,7 +1203,7 @@ def update_feature(
         name: str = None,
         resource: feature.Feature = None,
         update_mask: field_mask_pb2.FieldMask = None,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> operation.Operation:
@@ -1305,7 +1307,7 @@ def generate_connect_manifest(
         self,
         request: Union[service.GenerateConnectManifestRequest, dict] = None,
         *,
-        retry: retries.Retry = gapic_v1.method.DEFAULT,
+        retry: OptionalRetry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
     ) -> service.GenerateConnectManifestResponse: