diff --git a/google/cloud/datastream_v1alpha1/services/datastream/client.py b/google/cloud/datastream_v1alpha1/services/datastream/client.py index 870fecf..442c8a1 100644 --- a/google/cloud/datastream_v1alpha1/services/datastream/client.py +++ b/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 diff --git a/google/cloud/datastream_v1alpha1/services/datastream/transports/base.py b/google/cloud/datastream_v1alpha1/services/datastream/transports/base.py index 580dc3d..76b62a4 100644 --- a/google/cloud/datastream_v1alpha1/services/datastream/transports/base.py +++ b/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) diff --git a/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc.py b/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc.py index 5f6f471..6f5e27d 100644 --- a/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc.py +++ b/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc.py @@ -83,16 +83,16 @@ def __init__( api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint. If provided, it overrides the ``host`` argument and tries to create a mutual TLS channel with client SSL credentials from - ``client_cert_source`` or applicatin default SSL credentials. + ``client_cert_source`` or application default SSL credentials. client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]): Deprecated. A callback to provide client SSL certificate bytes and private key bytes, both in PEM format. It is ignored if ``api_mtls_endpoint`` is None. ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials - for grpc channel. It is ignored if ``channel`` is provided. + for the grpc channel. It is ignored if ``channel`` is provided. client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]): A callback to provide client certificate bytes and private key bytes, - both in PEM format. It is used to configure mutual TLS channel. It is + both in PEM format. It is used to configure a mutual TLS channel. It is ignored if ``channel`` or ``ssl_channel_credentials`` is provided. quota_project_id (Optional[str]): An optional project to use for billing and quota. diff --git a/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc_asyncio.py b/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc_asyncio.py index d5a31cc..54004eb 100644 --- a/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc_asyncio.py +++ b/google/cloud/datastream_v1alpha1/services/datastream/transports/grpc_asyncio.py @@ -130,16 +130,16 @@ def __init__( api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint. If provided, it overrides the ``host`` argument and tries to create a mutual TLS channel with client SSL credentials from - ``client_cert_source`` or applicatin default SSL credentials. + ``client_cert_source`` or application default SSL credentials. client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]): Deprecated. A callback to provide client SSL certificate bytes and private key bytes, both in PEM format. It is ignored if ``api_mtls_endpoint`` is None. ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials - for grpc channel. It is ignored if ``channel`` is provided. + for the grpc channel. It is ignored if ``channel`` is provided. client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]): A callback to provide client certificate bytes and private key bytes, - both in PEM format. It is used to configure mutual TLS channel. It is + both in PEM format. It is used to configure a mutual TLS channel. It is ignored if ``channel`` or ``ssl_channel_credentials`` is provided. quota_project_id (Optional[str]): An optional project to use for billing and quota. diff --git a/scripts/fixup_datastream_v1alpha1_keywords.py b/scripts/fixup_datastream_v1alpha1_keywords.py index 44097c6..636ec17 100644 --- a/scripts/fixup_datastream_v1alpha1_keywords.py +++ b/scripts/fixup_datastream_v1alpha1_keywords.py @@ -39,27 +39,27 @@ def partition( class datastreamCallTransformer(cst.CSTTransformer): CTRL_PARAMS: Tuple[str] = ('retry', 'timeout', 'metadata') METHOD_TO_PARAMS: Dict[str, Tuple[str]] = { - 'create_connection_profile': ('parent', 'connection_profile_id', 'connection_profile', 'request_id', ), - 'create_private_connection': ('parent', 'private_connection_id', 'private_connection', 'request_id', ), - 'create_route': ('parent', 'route_id', 'route', 'request_id', ), - 'create_stream': ('parent', 'stream_id', 'stream', 'request_id', 'validate_only', 'force', ), - 'delete_connection_profile': ('name', 'request_id', ), - 'delete_private_connection': ('name', 'request_id', 'force', ), - 'delete_route': ('name', 'request_id', ), - 'delete_stream': ('name', 'request_id', ), - 'discover_connection_profile': ('parent', 'connection_profile', 'connection_profile_name', 'recursive', 'recursion_depth', 'oracle_rdbms', 'mysql_rdbms', ), - 'fetch_errors': ('stream', ), - 'fetch_static_ips': ('name', 'page_size', 'page_token', ), - 'get_connection_profile': ('name', ), - 'get_private_connection': ('name', ), - 'get_route': ('name', ), - 'get_stream': ('name', ), - 'list_connection_profiles': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), - 'list_private_connections': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), - 'list_routes': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), - 'list_streams': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), - 'update_connection_profile': ('connection_profile', 'update_mask', 'request_id', ), - 'update_stream': ('stream', 'update_mask', 'request_id', 'validate_only', 'force', ), + 'create_connection_profile': ('parent', 'connection_profile_id', 'connection_profile', 'request_id', ), + 'create_private_connection': ('parent', 'private_connection_id', 'private_connection', 'request_id', ), + 'create_route': ('parent', 'route_id', 'route', 'request_id', ), + 'create_stream': ('parent', 'stream_id', 'stream', 'request_id', 'validate_only', 'force', ), + 'delete_connection_profile': ('name', 'request_id', ), + 'delete_private_connection': ('name', 'request_id', 'force', ), + 'delete_route': ('name', 'request_id', ), + 'delete_stream': ('name', 'request_id', ), + 'discover_connection_profile': ('parent', 'connection_profile', 'connection_profile_name', 'recursive', 'recursion_depth', 'oracle_rdbms', 'mysql_rdbms', ), + 'fetch_errors': ('stream', ), + 'fetch_static_ips': ('name', 'page_size', 'page_token', ), + 'get_connection_profile': ('name', ), + 'get_private_connection': ('name', ), + 'get_route': ('name', ), + 'get_stream': ('name', ), + 'list_connection_profiles': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), + 'list_private_connections': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), + 'list_routes': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), + 'list_streams': ('parent', 'page_size', 'page_token', 'filter', 'order_by', ), + 'update_connection_profile': ('connection_profile', 'update_mask', 'request_id', ), + 'update_stream': ('stream', 'update_mask', 'request_id', 'validate_only', 'force', ), } def leave_Call(self, original: cst.Call, updated: cst.Call) -> cst.CSTNode: @@ -78,7 +78,7 @@ def leave_Call(self, original: cst.Call, updated: cst.Call) -> cst.CSTNode: return updated kwargs, ctrl_kwargs = partition( - lambda a: not a.keyword.value in self.CTRL_PARAMS, + lambda a: a.keyword.value not in self.CTRL_PARAMS, kwargs )