chore: use gapic-generator-python 0.65.1 (#31)

* chore: use gapic-generator-python 0.65.1

PiperOrigin-RevId: 441524537

Source-Link: googleapis/googleapis@2a27391

Source-Link: googleapis/googleapis-gen@ab6756a
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYWI2NzU2YTQ4Yzg5YjViY2I5ZmI3MzQ0M2NiOGU1NWQ1NzRmNDY0MyJ9

* 🦉 Updates from OwlBot post-processor

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

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

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/content_service/async_client.py

@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/content_service/client.py

@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/content_service/transports/base.py

@@ -83,6 +83,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -203,5 +204,9 @@ def list_content(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("ContentServiceTransport",)

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/content_service/transports/grpc.py

@@ -361,5 +361,9 @@ def list_content(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("ContentServiceGrpcTransport",)

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/dataplex_service/async_client.py

@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -516,7 +516,6 @@ async def delete_lake(
         r"""Deletes a lake resource. All zones within the lake
         must be deleted before the lake can be deleted.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1
@@ -1257,7 +1256,6 @@ async def delete_zone(
         r"""Deletes a zone resource. All assets within a zone
         must be deleted before the zone can be deleted.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1
@@ -1978,7 +1976,6 @@ async def delete_asset(
         resource is detached (default) or deleted based on the
         associated Lifecycle policy.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1
@@ -3585,7 +3582,6 @@ async def delete_environment(
         resources must have been deleted before environment
         deletion can be initiated.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/dataplex_service/client.py

@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -904,7 +904,6 @@ def delete_lake(
         r"""Deletes a lake resource. All zones within the lake
         must be deleted before the lake can be deleted.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1
@@ -1618,7 +1617,6 @@ def delete_zone(
         r"""Deletes a zone resource. All assets within a zone
         must be deleted before the zone can be deleted.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1
@@ -2312,7 +2310,6 @@ def delete_asset(
         resource is detached (default) or deleted based on the
         associated Lifecycle policy.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1
@@ -3856,7 +3853,6 @@ def delete_environment(
         resources must have been deleted before environment
         deletion can be initiated.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/dataplex_service/transports/base.py

@@ -86,6 +86,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -700,5 +701,9 @@ def list_sessions(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("DataplexServiceTransport",)

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/dataplex_service/transports/grpc.py

@@ -1082,5 +1082,9 @@ def list_sessions(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("DataplexServiceGrpcTransport",)

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/metadata_service/async_client.py

@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -332,7 +332,6 @@ async def update_entity(
         r"""Update a metadata entity. Only supports full resource
         update.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/metadata_service/client.py

@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -610,7 +610,6 @@ def update_entity(
         r"""Update a metadata entity. Only supports full resource
         update.
 
-
         .. code-block:: python
 
             from google.cloud import dataplex_v1

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/metadata_service/transports/base.py

@@ -81,6 +81,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -299,5 +300,9 @@ def list_partitions(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("MetadataServiceTransport",)

packages/google-cloud-dataplex/google/cloud/dataplex_v1/services/metadata_service/transports/grpc.py

@@ -465,5 +465,9 @@ def list_partitions(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("MetadataServiceGrpcTransport",)

packages/google-cloud-dataplex/google/cloud/dataplex_v1/types/analyze.py

@@ -51,7 +51,7 @@ class Environment(proto.Message):
         update_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The time when the environment
             was last updated.
-        labels (Sequence[google.cloud.dataplex_v1.types.Environment.LabelsEntry]):
+        labels (Mapping[str, str]):
             Optional. User defined labels for the
             environment.
         description (str):
@@ -138,7 +138,7 @@ class OsImageRuntime(proto.Message):
                     installed. Valid formats include Cloud Storage
                     URI to a PIP installable library. For example,
                     gs://bucket-name/my/path/to/lib.tar.gz
-                properties (Sequence[google.cloud.dataplex_v1.types.Environment.InfrastructureSpec.OsImageRuntime.PropertiesEntry]):
+                properties (Mapping[str, str]):
                     Optional. Spark properties to provide configuration for use
                     in sessions created for this environment. The properties to
                     set on daemon config files. Property keys are specified in
@@ -327,7 +327,7 @@ class Content(proto.Message):
         update_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The time when the content was
             last updated.
-        labels (Sequence[google.cloud.dataplex_v1.types.Content.LabelsEntry]):
+        labels (Mapping[str, str]):
             Optional. User defined labels for the
             content.
         description (str):

packages/google-cloud-dataplex/google/cloud/dataplex_v1/types/logs.py

@@ -95,7 +95,7 @@ class ConfigDetails(proto.Message):
         r"""Details about configuration events.
 
         Attributes:
-            parameters (Sequence[google.cloud.dataplex_v1.types.DiscoveryEvent.ConfigDetails.ParametersEntry]):
+            parameters (Mapping[str, str]):
                 A list of discovery configuration parameters
                 in effect. The keys are the field paths within
                 DiscoverySpec. Eg. includePatterns,

packages/google-cloud-dataplex/google/cloud/dataplex_v1/types/resources.py

@@ -71,7 +71,7 @@ class Lake(proto.Message):
         update_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The time when the lake was last
             updated.
-        labels (Sequence[google.cloud.dataplex_v1.types.Lake.LabelsEntry]):
+        labels (Mapping[str, str]):
             Optional. User-defined labels for the lake.
         description (str):
             Optional. Description of the lake.
@@ -265,7 +265,7 @@ class Zone(proto.Message):
         update_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The time when the zone was last
             updated.
-        labels (Sequence[google.cloud.dataplex_v1.types.Zone.LabelsEntry]):
+        labels (Mapping[str, str]):
             Optional. User defined labels for the zone.
         description (str):
             Optional. Description of the zone.
@@ -846,7 +846,7 @@ class Asset(proto.Message):
         update_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The time when the asset was last
             updated.
-        labels (Sequence[google.cloud.dataplex_v1.types.Asset.LabelsEntry]):
+        labels (Mapping[str, str]):
             Optional. User defined labels for the asset.
         description (str):
             Optional. Description of the asset.

packages/google-cloud-dataplex/google/cloud/dataplex_v1/types/tasks.py

@@ -57,7 +57,7 @@ class Task(proto.Message):
             Optional. User friendly display name.
         state (google.cloud.dataplex_v1.types.State):
             Output only. Current state of the task.
-        labels (Sequence[google.cloud.dataplex_v1.types.Task.LabelsEntry]):
+        labels (Mapping[str, str]):
             Optional. User-defined labels for the task.
         trigger_spec (google.cloud.dataplex_v1.types.Task.TriggerSpec):
             Required. Spec related to how often and when
@@ -128,7 +128,7 @@ class ContainerImageRuntime(proto.Message):
                     formats include Cloud Storage URI to a PIP installable
                     library. For example,
                     ``gs://bucket-name/my/path/to/lib.tar.gz``.
-                properties (Sequence[google.cloud.dataplex_v1.types.Task.InfrastructureSpec.ContainerImageRuntime.PropertiesEntry]):
+                properties (Mapping[str, str]):
                     Optional. Override to common configuration of open source
                     components installed on the Dataproc cluster. The properties
                     to set on daemon config files. Property keys are specified
@@ -282,7 +282,7 @@ class ExecutionSpec(proto.Message):
         r"""Execution related settings, like retry and service_account.
 
         Attributes:
-            args (Sequence[google.cloud.dataplex_v1.types.Task.ExecutionSpec.ArgsEntry]):
+            args (Mapping[str, str]):
                 Optional. The arguments to pass to the task. The args can
                 use placeholders of the format ${placeholder} as part of
                 key/value string. These will be interpolated before passing