chore: [Many APIs] Update gapic-generator-python to v1.19.1 (#13152)

- [ ] Regenerate this pull request now.

PiperOrigin-RevId: 684571179

Source-Link:
googleapis/googleapis@fbdc238

Source-Link:
googleapis/googleapis-gen@3a2cdcf
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LWRhdGF0cmFuc2Zlci8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LWxvZ2dpbmcvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ==
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LW1pZ3JhdGlvbi8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LXJlc2VydmF0aW9uLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpbGxpbmctYnVkZ2V0cy8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpbGxpbmcvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ==
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpbmFyeS1hdXRob3JpemF0aW9uLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJ1aWxkLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNlcnRpZmljYXRlLW1hbmFnZXIvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ==
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNoYW5uZWwvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ==
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNsb3VkY29udHJvbHNwYXJ0bmVyLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNsb3VkcXVvdGFzLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbW1lcmNlLWNvbnN1bWVyLXByb2N1cmVtZW50Ly5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbW1vbi8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbXB1dGUvLk93bEJvdC55YW1sIiwiaCI6IjNhMmNkY2ZiODBjMmQwZjVlYzBjYzY2M2MyYmFiMGE5NDg2MjI5ZDAifQ==
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbmZpZGVudGlhbGNvbXB1dGluZy8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbmZpZy8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRhY3QtY2VudGVyLWluc2lnaHRzLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRhaW5lci8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWNvbnRhaW5lcmFuYWx5c2lzLy5Pd2xCb3QueWFtbCIsImgiOiIzYTJjZGNmYjgwYzJkMGY1ZWMwY2M2NjNjMmJhYjBhOTQ4NjIyOWQwIn0=

---------

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

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "3.16.0"  # {x-release-please-version}
+__version__ = "0.0.0"  # {x-release-please-version}

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer_v1/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "3.16.0"  # {x-release-please-version}
+__version__ = "0.0.0"  # {x-release-please-version}

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer_v1/services/data_transfer_service/async_client.py

@@ -2108,11 +2108,7 @@ async def get_location(
 
         # Wrap the RPC method; this adds retry and timeout information,
         # and friendly error handling.
-        rpc = gapic_v1.method_async.wrap_method(
-            self._client._transport.get_location,
-            default_timeout=None,
-            client_info=DEFAULT_CLIENT_INFO,
-        )
+        rpc = self.transport._wrapped_methods[self._client._transport.get_location]
 
         # Certain fields should be provided within the metadata header;
         # add these here.
@@ -2165,11 +2161,7 @@ async def list_locations(
 
         # Wrap the RPC method; this adds retry and timeout information,
         # and friendly error handling.
-        rpc = gapic_v1.method_async.wrap_method(
-            self._client._transport.list_locations,
-            default_timeout=None,
-            client_info=DEFAULT_CLIENT_INFO,
-        )
+        rpc = self.transport._wrapped_methods[self._client._transport.list_locations]
 
         # Certain fields should be provided within the metadata header;
         # add these here.

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer_v1/services/data_transfer_service/client.py

@@ -2532,11 +2532,7 @@ def get_location(
 
         # Wrap the RPC method; this adds retry and timeout information,
         # and friendly error handling.
-        rpc = gapic_v1.method.wrap_method(
-            self._transport.get_location,
-            default_timeout=None,
-            client_info=DEFAULT_CLIENT_INFO,
-        )
+        rpc = self._transport._wrapped_methods[self._transport.get_location]
 
         # Certain fields should be provided within the metadata header;
         # add these here.
@@ -2589,11 +2585,7 @@ def list_locations(
 
         # Wrap the RPC method; this adds retry and timeout information,
         # and friendly error handling.
-        rpc = gapic_v1.method.wrap_method(
-            self._transport.list_locations,
-            default_timeout=None,
-            client_info=DEFAULT_CLIENT_INFO,
-        )
+        rpc = self._transport._wrapped_methods[self._transport.list_locations]
 
         # Certain fields should be provided within the metadata header;
         # add these here.

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer_v1/services/data_transfer_service/transports/README.rst

@@ -0,0 +1,9 @@
+
+transport inheritance structure
+_______________________________
+
+`DataTransferServiceTransport` is the ABC for all transports.
+- public child `DataTransferServiceGrpcTransport` for sync gRPC transport (defined in `grpc.py`).
+- public child `DataTransferServiceGrpcAsyncIOTransport` for async gRPC transport (defined in `grpc_asyncio.py`).
+- private child `_BaseDataTransferServiceRestTransport` for base REST transport with inner classes `_BaseMETHOD` (defined in `rest_base.py`).
+- public child `DataTransferServiceRestTransport` for sync REST transport with inner classes `METHOD` derived from the parent's corresponding `_BaseMETHOD` classes (defined in `rest.py`).

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer_v1/services/data_transfer_service/transports/base.py

@@ -310,6 +310,16 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=None,
                 client_info=client_info,
             ),
+            self.get_location: gapic_v1.method.wrap_method(
+                self.get_location,
+                default_timeout=None,
+                client_info=client_info,
+            ),
+            self.list_locations: gapic_v1.method.wrap_method(
+                self.list_locations,
+                default_timeout=None,
+                client_info=client_info,
+            ),
         }
 
     def close(self):

packages/google-cloud-bigquery-datatransfer/google/cloud/bigquery_datatransfer_v1/services/data_transfer_service/transports/grpc_asyncio.py

@@ -13,6 +13,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
+import inspect
 from typing import Awaitable, Callable, Dict, Optional, Sequence, Tuple, Union
 import warnings
 
@@ -229,6 +230,9 @@ def __init__(
             )
 
         # Wrap messages. This must be done after self._grpc_channel exists
+        self._wrap_with_kind = (
+            "kind" in inspect.signature(gapic_v1.method_async.wrap_method).parameters
+        )
         self._prep_wrapped_messages(client_info)
 
     @property
@@ -724,7 +728,7 @@ def unenroll_data_sources(
     def _prep_wrapped_messages(self, client_info):
         """Precompute the wrapped methods, overriding the base class method to use async wrappers."""
         self._wrapped_methods = {
-            self.get_data_source: gapic_v1.method_async.wrap_method(
+            self.get_data_source: self._wrap_method(
                 self.get_data_source,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -739,7 +743,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.list_data_sources: gapic_v1.method_async.wrap_method(
+            self.list_data_sources: self._wrap_method(
                 self.list_data_sources,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -754,17 +758,17 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.create_transfer_config: gapic_v1.method_async.wrap_method(
+            self.create_transfer_config: self._wrap_method(
                 self.create_transfer_config,
                 default_timeout=30.0,
                 client_info=client_info,
             ),
-            self.update_transfer_config: gapic_v1.method_async.wrap_method(
+            self.update_transfer_config: self._wrap_method(
                 self.update_transfer_config,
                 default_timeout=30.0,
                 client_info=client_info,
             ),
-            self.delete_transfer_config: gapic_v1.method_async.wrap_method(
+            self.delete_transfer_config: self._wrap_method(
                 self.delete_transfer_config,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -779,7 +783,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.get_transfer_config: gapic_v1.method_async.wrap_method(
+            self.get_transfer_config: self._wrap_method(
                 self.get_transfer_config,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -794,7 +798,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.list_transfer_configs: gapic_v1.method_async.wrap_method(
+            self.list_transfer_configs: self._wrap_method(
                 self.list_transfer_configs,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -809,17 +813,17 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.schedule_transfer_runs: gapic_v1.method_async.wrap_method(
+            self.schedule_transfer_runs: self._wrap_method(
                 self.schedule_transfer_runs,
                 default_timeout=30.0,
                 client_info=client_info,
             ),
-            self.start_manual_transfer_runs: gapic_v1.method_async.wrap_method(
+            self.start_manual_transfer_runs: self._wrap_method(
                 self.start_manual_transfer_runs,
                 default_timeout=None,
                 client_info=client_info,
             ),
-            self.get_transfer_run: gapic_v1.method_async.wrap_method(
+            self.get_transfer_run: self._wrap_method(
                 self.get_transfer_run,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -834,7 +838,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.delete_transfer_run: gapic_v1.method_async.wrap_method(
+            self.delete_transfer_run: self._wrap_method(
                 self.delete_transfer_run,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -849,7 +853,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.list_transfer_runs: gapic_v1.method_async.wrap_method(
+            self.list_transfer_runs: self._wrap_method(
                 self.list_transfer_runs,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -864,7 +868,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.list_transfer_logs: gapic_v1.method_async.wrap_method(
+            self.list_transfer_logs: self._wrap_method(
                 self.list_transfer_logs,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -879,7 +883,7 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.check_valid_creds: gapic_v1.method_async.wrap_method(
+            self.check_valid_creds: self._wrap_method(
                 self.check_valid_creds,
                 default_retry=retries.AsyncRetry(
                     initial=0.1,
@@ -894,21 +898,40 @@ def _prep_wrapped_messages(self, client_info):
                 default_timeout=20.0,
                 client_info=client_info,
             ),
-            self.enroll_data_sources: gapic_v1.method_async.wrap_method(
+            self.enroll_data_sources: self._wrap_method(
                 self.enroll_data_sources,
                 default_timeout=None,
                 client_info=client_info,
             ),
-            self.unenroll_data_sources: gapic_v1.method_async.wrap_method(
+            self.unenroll_data_sources: self._wrap_method(
                 self.unenroll_data_sources,
                 default_timeout=None,
                 client_info=client_info,
             ),
+            self.get_location: self._wrap_method(
+                self.get_location,
+                default_timeout=None,
+                client_info=client_info,
+            ),
+            self.list_locations: self._wrap_method(
+                self.list_locations,
+                default_timeout=None,
+                client_info=client_info,
+            ),
         }
 
+    def _wrap_method(self, func, *args, **kwargs):
+        if self._wrap_with_kind:  # pragma: NO COVER
+            kwargs["kind"] = self.kind
+        return gapic_v1.method_async.wrap_method(func, *args, **kwargs)
+
     def close(self):
         return self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc_asyncio"
+
     @property
     def list_locations(
         self,