chore: use gapic-generator-python 0.51.2 (#29)

- [ ] Regenerate this pull request now.

fix: add 'dict' annotation type to 'request'

Committer: @busunkim96
PiperOrigin-RevId: 398509016

Source-Link: googleapis/googleapis@b224dfa

Source-Link: googleapis/googleapis-gen@63a1db7
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9

google/cloud/datastream_v1alpha1/services/datastream/client.py

@@ -17,7 +17,7 @@
 from distutils import util
 import os
 import re
-from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib  # type: ignore
@@ -413,7 +413,7 @@ def __init__(
 
     def list_connection_profiles(
         self,
-        request: datastream.ListConnectionProfilesRequest = None,
+        request: Union[datastream.ListConnectionProfilesRequest, dict] = None,
         *,
         parent: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -424,7 +424,7 @@ def list_connection_profiles(
         in a project and location.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.ListConnectionProfilesRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.ListConnectionProfilesRequest, dict]):
                 The request object.
             parent (str):
                 Required. The parent that owns the
@@ -491,7 +491,7 @@ def list_connection_profiles(
 
     def get_connection_profile(
         self,
-        request: datastream.GetConnectionProfileRequest = None,
+        request: Union[datastream.GetConnectionProfileRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -502,7 +502,7 @@ def get_connection_profile(
         profile.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.GetConnectionProfileRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.GetConnectionProfileRequest, dict]):
                 The request object.
             name (str):
                 Required. The name of the connection
@@ -560,7 +560,7 @@ def get_connection_profile(
 
     def create_connection_profile(
         self,
-        request: datastream.CreateConnectionProfileRequest = None,
+        request: Union[datastream.CreateConnectionProfileRequest, dict] = None,
         *,
         parent: str = None,
         connection_profile: datastream_resources.ConnectionProfile = None,
@@ -573,7 +573,7 @@ def create_connection_profile(
         project and location.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.CreateConnectionProfileRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.CreateConnectionProfileRequest, dict]):
                 The request object.
             parent (str):
                 Required. The parent that owns the
@@ -663,7 +663,7 @@ def create_connection_profile(
 
     def update_connection_profile(
         self,
-        request: datastream.UpdateConnectionProfileRequest = None,
+        request: Union[datastream.UpdateConnectionProfileRequest, dict] = None,
         *,
         connection_profile: datastream_resources.ConnectionProfile = None,
         update_mask: field_mask_pb2.FieldMask = None,
@@ -675,7 +675,7 @@ def update_connection_profile(
         connection profile.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.UpdateConnectionProfileRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.UpdateConnectionProfileRequest, dict]):
                 The request object.
             connection_profile (google.cloud.datastream_v1alpha1.types.ConnectionProfile):
                 Required. The ConnectionProfile to
@@ -763,7 +763,7 @@ def update_connection_profile(
 
     def delete_connection_profile(
         self,
-        request: datastream.DeleteConnectionProfileRequest = None,
+        request: Union[datastream.DeleteConnectionProfileRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -773,7 +773,7 @@ def delete_connection_profile(
         r"""Use this method to delete a connection profile..
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.DeleteConnectionProfileRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.DeleteConnectionProfileRequest, dict]):
                 The request object.
             name (str):
                 Required. The name of the connection
@@ -856,7 +856,7 @@ def delete_connection_profile(
 
     def discover_connection_profile(
         self,
-        request: datastream.DiscoverConnectionProfileRequest = None,
+        request: Union[datastream.DiscoverConnectionProfileRequest, dict] = None,
         *,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
@@ -869,7 +869,7 @@ def discover_connection_profile(
         that's optionally supplied in the request.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.DiscoverConnectionProfileRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.DiscoverConnectionProfileRequest, dict]):
                 The request object. Request message for 'discover'
                 ConnectionProfile request.
             retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -910,7 +910,7 @@ def discover_connection_profile(
 
     def list_streams(
         self,
-        request: datastream.ListStreamsRequest = None,
+        request: Union[datastream.ListStreamsRequest, dict] = None,
         *,
         parent: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -921,7 +921,7 @@ def list_streams(
         location.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.ListStreamsRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.ListStreamsRequest, dict]):
                 The request object.
             parent (str):
                 Required. The parent that owns the
@@ -988,7 +988,7 @@ def list_streams(
 
     def get_stream(
         self,
-        request: datastream.GetStreamRequest = None,
+        request: Union[datastream.GetStreamRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -998,7 +998,7 @@ def get_stream(
         r"""Use this method to get details about a stream.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.GetStreamRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.GetStreamRequest, dict]):
                 The request object.
             name (str):
                 Required. The name of the stream
@@ -1056,7 +1056,7 @@ def get_stream(
 
     def create_stream(
         self,
-        request: datastream.CreateStreamRequest = None,
+        request: Union[datastream.CreateStreamRequest, dict] = None,
         *,
         parent: str = None,
         stream: datastream_resources.Stream = None,
@@ -1068,7 +1068,7 @@ def create_stream(
         r"""Use this method to create a stream.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.CreateStreamRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.CreateStreamRequest, dict]):
                 The request object.
             parent (str):
                 Required. The parent that owns the
@@ -1154,7 +1154,7 @@ def create_stream(
 
     def update_stream(
         self,
-        request: datastream.UpdateStreamRequest = None,
+        request: Union[datastream.UpdateStreamRequest, dict] = None,
         *,
         stream: datastream_resources.Stream = None,
         update_mask: field_mask_pb2.FieldMask = None,
@@ -1166,7 +1166,7 @@ def update_stream(
         stream.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.UpdateStreamRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.UpdateStreamRequest, dict]):
                 The request object.
             stream (google.cloud.datastream_v1alpha1.types.Stream):
                 Required. The stream resource to
@@ -1251,7 +1251,7 @@ def update_stream(
 
     def delete_stream(
         self,
-        request: datastream.DeleteStreamRequest = None,
+        request: Union[datastream.DeleteStreamRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1261,7 +1261,7 @@ def delete_stream(
         r"""Use this method to delete a stream.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.DeleteStreamRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.DeleteStreamRequest, dict]):
                 The request object.
             name (str):
                 Required. The name of the stream
@@ -1342,7 +1342,7 @@ def delete_stream(
 
     def fetch_errors(
         self,
-        request: datastream.FetchErrorsRequest = None,
+        request: Union[datastream.FetchErrorsRequest, dict] = None,
         *,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
@@ -1352,7 +1352,7 @@ def fetch_errors(
         stream.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.FetchErrorsRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.FetchErrorsRequest, dict]):
                 The request object. Request message for 'FetchErrors'
                 request.
             retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1404,7 +1404,7 @@ def fetch_errors(
 
     def fetch_static_ips(
         self,
-        request: datastream.FetchStaticIpsRequest = None,
+        request: Union[datastream.FetchStaticIpsRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1417,7 +1417,7 @@ def fetch_static_ips(
         optionally supplied in the request.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.FetchStaticIpsRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.FetchStaticIpsRequest, dict]):
                 The request object. Request message for 'FetchStaticIps'
                 request.
             name (str):
@@ -1487,7 +1487,7 @@ def fetch_static_ips(
 
     def create_private_connection(
         self,
-        request: datastream.CreatePrivateConnectionRequest = None,
+        request: Union[datastream.CreatePrivateConnectionRequest, dict] = None,
         *,
         parent: str = None,
         private_connection: datastream_resources.PrivateConnection = None,
@@ -1500,7 +1500,7 @@ def create_private_connection(
         configuration.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.CreatePrivateConnectionRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.CreatePrivateConnectionRequest, dict]):
                 The request object.
             parent (str):
                 Required. The parent that owns the
@@ -1590,7 +1590,7 @@ def create_private_connection(
 
     def get_private_connection(
         self,
-        request: datastream.GetPrivateConnectionRequest = None,
+        request: Union[datastream.GetPrivateConnectionRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1601,7 +1601,7 @@ def get_private_connection(
         connectivity configuration.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.GetPrivateConnectionRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.GetPrivateConnectionRequest, dict]):
                 The request object.
             name (str):
                 Required. The name of the  private
@@ -1663,7 +1663,7 @@ def get_private_connection(
 
     def list_private_connections(
         self,
-        request: datastream.ListPrivateConnectionsRequest = None,
+        request: Union[datastream.ListPrivateConnectionsRequest, dict] = None,
         *,
         parent: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1674,7 +1674,7 @@ def list_private_connections(
         configurations in a project and location.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.ListPrivateConnectionsRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.ListPrivateConnectionsRequest, dict]):
                 The request object.
             parent (str):
                 Required. The parent that owns the
@@ -1742,7 +1742,7 @@ def list_private_connections(
 
     def delete_private_connection(
         self,
-        request: datastream.DeletePrivateConnectionRequest = None,
+        request: Union[datastream.DeletePrivateConnectionRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1753,7 +1753,7 @@ def delete_private_connection(
         configuration.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.DeletePrivateConnectionRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.DeletePrivateConnectionRequest, dict]):
                 The request object.
             name (str):
                 Required. The name of the private
@@ -1836,7 +1836,7 @@ def delete_private_connection(
 
     def create_route(
         self,
-        request: datastream.CreateRouteRequest = None,
+        request: Union[datastream.CreateRouteRequest, dict] = None,
         *,
         parent: str = None,
         route: datastream_resources.Route = None,
@@ -1849,7 +1849,7 @@ def create_route(
         connectivity in a project and location.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.CreateRouteRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.CreateRouteRequest, dict]):
                 The request object. route creation request
             parent (str):
                 Required. The parent that owns the
@@ -1936,7 +1936,7 @@ def create_route(
 
     def get_route(
         self,
-        request: datastream.GetRouteRequest = None,
+        request: Union[datastream.GetRouteRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1946,7 +1946,7 @@ def get_route(
         r"""Use this method to get details about a route.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.GetRouteRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.GetRouteRequest, dict]):
                 The request object. route get request
             name (str):
                 Required. The name of the Route
@@ -2008,7 +2008,7 @@ def get_route(
 
     def list_routes(
         self,
-        request: datastream.ListRoutesRequest = None,
+        request: Union[datastream.ListRoutesRequest, dict] = None,
         *,
         parent: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -2019,7 +2019,7 @@ def list_routes(
         connectivity in a project and location.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.ListRoutesRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.ListRoutesRequest, dict]):
                 The request object. route list request
             parent (str):
                 Required. The parent that owns the
@@ -2087,7 +2087,7 @@ def list_routes(
 
     def delete_route(
         self,
-        request: datastream.DeleteRouteRequest = None,
+        request: Union[datastream.DeleteRouteRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -2097,7 +2097,7 @@ def delete_route(
         r"""Use this method to delete a route.
 
         Args:
-            request (google.cloud.datastream_v1alpha1.types.DeleteRouteRequest):
+            request (Union[google.cloud.datastream_v1alpha1.types.DeleteRouteRequest, dict]):
                 The request object. route deletion request
             name (str):
                 Required. The name of the Route

google/cloud/datastream_v1alpha1/services/datastream/transports/base.py

@@ -120,7 +120,7 @@ def __init__(
                 **scopes_kwargs, quota_project_id=quota_project_id
             )
 
-        # If the credentials is service account credentials, then always try to use self signed JWT.
+        # If the credentials are service account credentials, then always try to use self signed JWT.
         if (
             always_use_jwt_access
             and isinstance(credentials, service_account.Credentials)