Skip to content
Permalink
Browse files
chore: use gapic-generator-python 0.51.2 (#43)
- [ ] Regenerate this pull request now.

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

Committer: @busunkim96
PiperOrigin-RevId: 398509016

Source-Link: googleapis/googleapis@b224dfa

Source-Link: https://github.com/googleapis/googleapis-gen/commit/63a1db7a38d74b9639592f521ed1daaf7299ad9a
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9
  • Loading branch information
gcf-owl-bot[bot] committed Sep 24, 2021
1 parent fea5c58 commit f82e8653bf754d4dbb5f119f23eaa97fa8faf445
Show file tree
Hide file tree
Showing 5 changed files with 60 additions and 60 deletions.
@@ -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
@@ -380,7 +380,7 @@ def __init__(

def list_migration_jobs(
self,
request: clouddms.ListMigrationJobsRequest = None,
request: Union[clouddms.ListMigrationJobsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -390,7 +390,7 @@ def list_migration_jobs(
r"""Lists migration jobs in a given project and location.
Args:
request (google.cloud.clouddms_v1.types.ListMigrationJobsRequest):
request (Union[google.cloud.clouddms_v1.types.ListMigrationJobsRequest, dict]):
The request object. Retrieve a list of all migration
jobs in a given project and location.
parent (str):
@@ -460,7 +460,7 @@ def list_migration_jobs(

def get_migration_job(
self,
request: clouddms.GetMigrationJobRequest = None,
request: Union[clouddms.GetMigrationJobRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -470,7 +470,7 @@ def get_migration_job(
r"""Gets details of a single migration job.
Args:
request (google.cloud.clouddms_v1.types.GetMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.GetMigrationJobRequest, dict]):
The request object. Request message for
'GetMigrationJob' request.
name (str):
@@ -531,7 +531,7 @@ def get_migration_job(

def create_migration_job(
self,
request: clouddms.CreateMigrationJobRequest = None,
request: Union[clouddms.CreateMigrationJobRequest, dict] = None,
*,
parent: str = None,
migration_job: clouddms_resources.MigrationJob = None,
@@ -544,7 +544,7 @@ def create_migration_job(
location.
Args:
request (google.cloud.clouddms_v1.types.CreateMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.CreateMigrationJobRequest, dict]):
The request object. Request message to create a new
Database Migration Service migration job in the
specified project and region.
@@ -637,7 +637,7 @@ def create_migration_job(

def update_migration_job(
self,
request: clouddms.UpdateMigrationJobRequest = None,
request: Union[clouddms.UpdateMigrationJobRequest, dict] = None,
*,
migration_job: clouddms_resources.MigrationJob = None,
update_mask: field_mask_pb2.FieldMask = None,
@@ -648,7 +648,7 @@ def update_migration_job(
r"""Updates the parameters of a single migration job.
Args:
request (google.cloud.clouddms_v1.types.UpdateMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.UpdateMigrationJobRequest, dict]):
The request object. Request message for
'UpdateMigrationJob' request.
migration_job (google.cloud.clouddms_v1.types.MigrationJob):
@@ -734,7 +734,7 @@ def update_migration_job(

def delete_migration_job(
self,
request: clouddms.DeleteMigrationJobRequest = None,
request: Union[clouddms.DeleteMigrationJobRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -744,7 +744,7 @@ def delete_migration_job(
r"""Deletes a single migration job.
Args:
request (google.cloud.clouddms_v1.types.DeleteMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.DeleteMigrationJobRequest, dict]):
The request object. Request message for
'DeleteMigrationJob' request.
name (str):
@@ -826,7 +826,7 @@ def delete_migration_job(

def start_migration_job(
self,
request: clouddms.StartMigrationJobRequest = None,
request: Union[clouddms.StartMigrationJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -835,7 +835,7 @@ def start_migration_job(
r"""Start an already created migration job.
Args:
request (google.cloud.clouddms_v1.types.StartMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.StartMigrationJobRequest, dict]):
The request object. Request message for
'StartMigrationJob' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -888,7 +888,7 @@ def start_migration_job(

def stop_migration_job(
self,
request: clouddms.StopMigrationJobRequest = None,
request: Union[clouddms.StopMigrationJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -897,7 +897,7 @@ def stop_migration_job(
r"""Stops a running migration job.
Args:
request (google.cloud.clouddms_v1.types.StopMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.StopMigrationJobRequest, dict]):
The request object. Request message for
'StopMigrationJob' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -950,7 +950,7 @@ def stop_migration_job(

def resume_migration_job(
self,
request: clouddms.ResumeMigrationJobRequest = None,
request: Union[clouddms.ResumeMigrationJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -960,7 +960,7 @@ def resume_migration_job(
is resumable (was stopped during CDC phase).
Args:
request (google.cloud.clouddms_v1.types.ResumeMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.ResumeMigrationJobRequest, dict]):
The request object. Request message for
'ResumeMigrationJob' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1013,7 +1013,7 @@ def resume_migration_job(

def promote_migration_job(
self,
request: clouddms.PromoteMigrationJobRequest = None,
request: Union[clouddms.PromoteMigrationJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -1024,7 +1024,7 @@ def promote_migration_job(
standalone database.
Args:
request (google.cloud.clouddms_v1.types.PromoteMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.PromoteMigrationJobRequest, dict]):
The request object. Request message for
'PromoteMigrationJob' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1077,7 +1077,7 @@ def promote_migration_job(

def verify_migration_job(
self,
request: clouddms.VerifyMigrationJobRequest = None,
request: Union[clouddms.VerifyMigrationJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -1088,7 +1088,7 @@ def verify_migration_job(
prerequisites are met.
Args:
request (google.cloud.clouddms_v1.types.VerifyMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.VerifyMigrationJobRequest, dict]):
The request object. Request message for
'VerifyMigrationJob' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1141,7 +1141,7 @@ def verify_migration_job(

def restart_migration_job(
self,
request: clouddms.RestartMigrationJobRequest = None,
request: Union[clouddms.RestartMigrationJobRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -1152,7 +1152,7 @@ def restart_migration_job(
starting the migration process from scratch.
Args:
request (google.cloud.clouddms_v1.types.RestartMigrationJobRequest):
request (Union[google.cloud.clouddms_v1.types.RestartMigrationJobRequest, dict]):
The request object. Request message for
'RestartMigrationJob' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1205,7 +1205,7 @@ def restart_migration_job(

def generate_ssh_script(
self,
request: clouddms.GenerateSshScriptRequest = None,
request: Union[clouddms.GenerateSshScriptRequest, dict] = None,
*,
retry: retries.Retry = gapic_v1.method.DEFAULT,
timeout: float = None,
@@ -1215,7 +1215,7 @@ def generate_ssh_script(
reverse SSH connectivity.
Args:
request (google.cloud.clouddms_v1.types.GenerateSshScriptRequest):
request (Union[google.cloud.clouddms_v1.types.GenerateSshScriptRequest, dict]):
The request object. Request message for
'GenerateSshScript' request.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -1258,7 +1258,7 @@ def generate_ssh_script(

def list_connection_profiles(
self,
request: clouddms.ListConnectionProfilesRequest = None,
request: Union[clouddms.ListConnectionProfilesRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1269,7 +1269,7 @@ def list_connection_profiles(
project and location.
Args:
request (google.cloud.clouddms_v1.types.ListConnectionProfilesRequest):
request (Union[google.cloud.clouddms_v1.types.ListConnectionProfilesRequest, dict]):
The request object. Request message for
'ListConnectionProfiles' request.
parent (str):
@@ -1339,7 +1339,7 @@ def list_connection_profiles(

def get_connection_profile(
self,
request: clouddms.GetConnectionProfileRequest = None,
request: Union[clouddms.GetConnectionProfileRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1349,7 +1349,7 @@ def get_connection_profile(
r"""Gets details of a single connection profile.
Args:
request (google.cloud.clouddms_v1.types.GetConnectionProfileRequest):
request (Union[google.cloud.clouddms_v1.types.GetConnectionProfileRequest, dict]):
The request object. Request message for
'GetConnectionProfile' request.
name (str):
@@ -1408,7 +1408,7 @@ def get_connection_profile(

def create_connection_profile(
self,
request: clouddms.CreateConnectionProfileRequest = None,
request: Union[clouddms.CreateConnectionProfileRequest, dict] = None,
*,
parent: str = None,
connection_profile: clouddms_resources.ConnectionProfile = None,
@@ -1421,7 +1421,7 @@ def create_connection_profile(
and location.
Args:
request (google.cloud.clouddms_v1.types.CreateConnectionProfileRequest):
request (Union[google.cloud.clouddms_v1.types.CreateConnectionProfileRequest, dict]):
The request object. Request message for
'CreateConnectionProfile' request.
parent (str):
@@ -1513,7 +1513,7 @@ def create_connection_profile(

def update_connection_profile(
self,
request: clouddms.UpdateConnectionProfileRequest = None,
request: Union[clouddms.UpdateConnectionProfileRequest, dict] = None,
*,
connection_profile: clouddms_resources.ConnectionProfile = None,
update_mask: field_mask_pb2.FieldMask = None,
@@ -1525,7 +1525,7 @@ def update_connection_profile(
profile.
Args:
request (google.cloud.clouddms_v1.types.UpdateConnectionProfileRequest):
request (Union[google.cloud.clouddms_v1.types.UpdateConnectionProfileRequest, dict]):
The request object. Request message for
'UpdateConnectionProfile' request.
connection_profile (google.cloud.clouddms_v1.types.ConnectionProfile):
@@ -1612,7 +1612,7 @@ def update_connection_profile(

def delete_connection_profile(
self,
request: clouddms.DeleteConnectionProfileRequest = None,
request: Union[clouddms.DeleteConnectionProfileRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1625,7 +1625,7 @@ def delete_connection_profile(
jobs.
Args:
request (google.cloud.clouddms_v1.types.DeleteConnectionProfileRequest):
request (Union[google.cloud.clouddms_v1.types.DeleteConnectionProfileRequest, dict]):
The request object. Request message for
'DeleteConnectionProfile' request.
name (str):
@@ -118,7 +118,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)
@@ -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.
@@ -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.

0 comments on commit f82e865

Please sign in to comment.