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

* 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>
Co-authored-by: Anthonios Partheniou <partheniou@google.com>

google/pubsub_v1/services/publisher/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
@@ -220,7 +220,6 @@ async def create_topic(
         name rules]
         (https://cloud.google.com/pubsub/docs/admin#resource_names).
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -329,7 +328,6 @@ async def update_topic(
         r"""Updates an existing topic. Note that certain
         properties of a topic are not modifiable.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -418,7 +416,6 @@ async def publish(
         r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
         the topic does not exist.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -758,7 +755,6 @@ async def list_topic_subscriptions(
         r"""Lists the names of the attached subscriptions on this
         topic.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -884,7 +880,6 @@ async def list_topic_snapshots(
         bulk. That is, you can set the acknowledgment state of messages
         in an existing subscription to the state captured by a snapshot.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1010,7 +1005,6 @@ async def delete_topic(
         subscriptions to this topic are not deleted, but their ``topic``
         field is set to ``_deleted-topic_``.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1107,7 +1101,6 @@ async def detach_subscription(
         the subscription is a push subscription, pushes to the endpoint
         will stop.
 
-
         .. code-block:: python
 
             from google import pubsub_v1

google/pubsub_v1/services/publisher/client.py

@@ -17,7 +17,7 @@
 import functools
 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
@@ -503,7 +503,6 @@ def create_topic(
         name rules]
         (https://cloud.google.com/pubsub/docs/admin#resource_names).
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -604,7 +603,6 @@ def update_topic(
         r"""Updates an existing topic. Note that certain
         properties of a topic are not modifiable.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -686,7 +684,6 @@ def publish(
         r"""Adds one or more messages to the topic. Returns ``NOT_FOUND`` if
         the topic does not exist.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -992,7 +989,6 @@ def list_topic_subscriptions(
         r"""Lists the names of the attached subscriptions on this
         topic.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1108,7 +1104,6 @@ def list_topic_snapshots(
         bulk. That is, you can set the acknowledgment state of messages
         in an existing subscription to the state captured by a snapshot.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1224,7 +1219,6 @@ def delete_topic(
         subscriptions to this topic are not deleted, but their ``topic``
         field is set to ``_deleted-topic_``.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1313,7 +1307,6 @@ def detach_subscription(
         the subscription is a push subscription, pushes to the endpoint
         will stop.
 
-
         .. code-block:: python
 
             from google import pubsub_v1

google/pubsub_v1/services/publisher/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"
@@ -391,5 +392,9 @@ def test_iam_permissions(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("PublisherTransport",)

google/pubsub_v1/services/publisher/transports/grpc.py

@@ -565,5 +565,9 @@ def test_iam_permissions(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("PublisherGrpcTransport",)

google/pubsub_v1/services/schema_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

google/pubsub_v1/services/schema_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

google/pubsub_v1/services/schema_service/transports/base.py

@@ -87,6 +87,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"
@@ -255,5 +256,9 @@ def test_iam_permissions(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("SchemaServiceTransport",)

google/pubsub_v1/services/schema_service/transports/grpc.py

@@ -468,5 +468,9 @@ def test_iam_permissions(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("SchemaServiceGrpcTransport",)

google/pubsub_v1/services/subscriber/async_client.py

@@ -18,6 +18,7 @@
 import re
 from typing import (
     Dict,
+    Mapping,
     Optional,
     AsyncIterable,
     Awaitable,
@@ -245,7 +246,6 @@ async def create_subscription(
         Note that for REST API requests, you must specify a name in the
         request.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -518,7 +518,6 @@ async def update_subscription(
         properties of a subscription, such as its topic, are not
         modifiable.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -729,7 +728,6 @@ async def delete_subscription(
         new one has no association with the old subscription or its
         topic unless the same topic is specified.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -831,7 +829,6 @@ async def modify_ack_deadline(
         does not modify the subscription-level ``ackDeadlineSeconds``
         used for subsequent messages.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -961,7 +958,6 @@ async def acknowledge(
         Acknowledging a message more than once will not result in an
         error.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1071,7 +1067,6 @@ async def pull(
         ``UNAVAILABLE`` if there are too many concurrent pull requests
         pending for the given subscription.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1219,7 +1214,6 @@ def streaming_pull(
         re-establish the stream. Flow control can be achieved by
         configuring the underlying RPC channel.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1321,7 +1315,6 @@ async def modify_push_config(
         Messages will accumulate for delivery continuously through the
         call regardless of changes to the ``PushConfig``.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1436,7 +1429,6 @@ async def get_snapshot(
         acknowledgment state of messages in an existing
         subscription to the state captured by a snapshot.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1550,7 +1542,6 @@ async def list_snapshots(
         bulk. That is, you can set the acknowledgment state of messages
         in an existing subscription to the state captured by a snapshot.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1688,7 +1679,6 @@ async def create_snapshot(
         Note that for REST API requests, you must specify a name in the
         request.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1826,7 +1816,6 @@ async def update_snapshot(
         existing subscription to the state captured by a
         snapshot.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -1924,7 +1913,6 @@ async def delete_snapshot(
         no association with the old snapshot or its subscription, unless
         the same subscription is specified.
 
-
         .. code-block:: python
 
             from google import pubsub_v1
@@ -2024,7 +2012,6 @@ async def seek(
         Note that both the subscription and the snapshot must be on the
         same topic.
 
-
         .. code-block:: python
 
             from google import pubsub_v1