Skip to content
This repository was archived by the owner on Jun 8, 2026. It is now read-only.
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -443,7 +443,7 @@ def __init__(

def list_databases(
self,
request: spanner_database_admin.ListDatabasesRequest = None,
request: Union[spanner_database_admin.ListDatabasesRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -453,7 +453,7 @@ def list_databases(
r"""Lists Cloud Spanner databases.

Args:
request (google.cloud.spanner_admin_database_v1.types.ListDatabasesRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.ListDatabasesRequest, dict]):
The request object. The request for
[ListDatabases][google.spanner.admin.database.v1.DatabaseAdmin.ListDatabases].
parent (str):
Expand Down Expand Up @@ -524,7 +524,7 @@ def list_databases(

def create_database(
self,
request: spanner_database_admin.CreateDatabaseRequest = None,
request: Union[spanner_database_admin.CreateDatabaseRequest, dict] = None,
*,
parent: str = None,
create_statement: str = None,
Expand All @@ -544,7 +544,7 @@ def create_database(
successful.

Args:
request (google.cloud.spanner_admin_database_v1.types.CreateDatabaseRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.CreateDatabaseRequest, dict]):
The request object. The request for
[CreateDatabase][google.spanner.admin.database.v1.DatabaseAdmin.CreateDatabase].
parent (str):
Expand Down Expand Up @@ -631,7 +631,7 @@ def create_database(

def get_database(
self,
request: spanner_database_admin.GetDatabaseRequest = None,
request: Union[spanner_database_admin.GetDatabaseRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -641,7 +641,7 @@ def get_database(
r"""Gets the state of a Cloud Spanner database.

Args:
request (google.cloud.spanner_admin_database_v1.types.GetDatabaseRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.GetDatabaseRequest, dict]):
The request object. The request for
[GetDatabase][google.spanner.admin.database.v1.DatabaseAdmin.GetDatabase].
name (str):
Expand Down Expand Up @@ -701,7 +701,7 @@ def get_database(

def update_database_ddl(
self,
request: spanner_database_admin.UpdateDatabaseDdlRequest = None,
request: Union[spanner_database_admin.UpdateDatabaseDdlRequest, dict] = None,
*,
database: str = None,
statements: Sequence[str] = None,
Expand All @@ -720,7 +720,7 @@ def update_database_ddl(
The operation has no response.

Args:
request (google.cloud.spanner_admin_database_v1.types.UpdateDatabaseDdlRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.UpdateDatabaseDdlRequest, dict]):
The request object. Enqueues the given DDL statements to
be applied, in order but not necessarily all at once, to
the database schema at some point (or points) in the
Expand Down Expand Up @@ -826,7 +826,7 @@ def update_database_ddl(

def drop_database(
self,
request: spanner_database_admin.DropDatabaseRequest = None,
request: Union[spanner_database_admin.DropDatabaseRequest, dict] = None,
*,
database: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -838,7 +838,7 @@ def drop_database(
``expire_time``.

Args:
request (google.cloud.spanner_admin_database_v1.types.DropDatabaseRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.DropDatabaseRequest, dict]):
The request object. The request for
[DropDatabase][google.spanner.admin.database.v1.DatabaseAdmin.DropDatabase].
database (str):
Expand Down Expand Up @@ -890,7 +890,7 @@ def drop_database(

def get_database_ddl(
self,
request: spanner_database_admin.GetDatabaseDdlRequest = None,
request: Union[spanner_database_admin.GetDatabaseDdlRequest, dict] = None,
*,
database: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -903,7 +903,7 @@ def get_database_ddl(
[Operations][google.longrunning.Operations] API.

Args:
request (google.cloud.spanner_admin_database_v1.types.GetDatabaseDdlRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.GetDatabaseDdlRequest, dict]):
The request object. The request for
[GetDatabaseDdl][google.spanner.admin.database.v1.DatabaseAdmin.GetDatabaseDdl].
database (str):
Expand Down Expand Up @@ -965,7 +965,7 @@ def get_database_ddl(

def set_iam_policy(
self,
request: iam_policy_pb2.SetIamPolicyRequest = None,
request: Union[iam_policy_pb2.SetIamPolicyRequest, dict] = None,
*,
resource: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -983,7 +983,7 @@ def set_iam_policy(
[resource][google.iam.v1.SetIamPolicyRequest.resource].

Args:
request (google.iam.v1.iam_policy_pb2.SetIamPolicyRequest):
request (Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]):
The request object. Request message for `SetIamPolicy`
method.
resource (str):
Expand Down Expand Up @@ -1098,7 +1098,7 @@ def set_iam_policy(

def get_iam_policy(
self,
request: iam_policy_pb2.GetIamPolicyRequest = None,
request: Union[iam_policy_pb2.GetIamPolicyRequest, dict] = None,
*,
resource: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -1117,7 +1117,7 @@ def get_iam_policy(
[resource][google.iam.v1.GetIamPolicyRequest.resource].

Args:
request (google.iam.v1.iam_policy_pb2.GetIamPolicyRequest):
request (Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]):
The request object. Request message for `GetIamPolicy`
method.
resource (str):
Expand Down Expand Up @@ -1232,7 +1232,7 @@ def get_iam_policy(

def test_iam_permissions(
self,
request: iam_policy_pb2.TestIamPermissionsRequest = None,
request: Union[iam_policy_pb2.TestIamPermissionsRequest, dict] = None,
*,
resource: str = None,
permissions: Sequence[str] = None,
Expand All @@ -1252,7 +1252,7 @@ def test_iam_permissions(
permission on the containing instance.

Args:
request (google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest):
request (Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]):
The request object. Request message for
`TestIamPermissions` method.
resource (str):
Expand Down Expand Up @@ -1323,7 +1323,7 @@ def test_iam_permissions(

def create_backup(
self,
request: gsad_backup.CreateBackupRequest = None,
request: Union[gsad_backup.CreateBackupRequest, dict] = None,
*,
parent: str = None,
backup: gsad_backup.Backup = None,
Expand All @@ -1347,7 +1347,7 @@ def create_backup(
databases can run concurrently.

Args:
request (google.cloud.spanner_admin_database_v1.types.CreateBackupRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.CreateBackupRequest, dict]):
The request object. The request for
[CreateBackup][google.spanner.admin.database.v1.DatabaseAdmin.CreateBackup].
parent (str):
Expand Down Expand Up @@ -1442,7 +1442,7 @@ def create_backup(

def get_backup(
self,
request: backup.GetBackupRequest = None,
request: Union[backup.GetBackupRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -1453,7 +1453,7 @@ def get_backup(
[Backup][google.spanner.admin.database.v1.Backup].

Args:
request (google.cloud.spanner_admin_database_v1.types.GetBackupRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.GetBackupRequest, dict]):
The request object. The request for
[GetBackup][google.spanner.admin.database.v1.DatabaseAdmin.GetBackup].
name (str):
Expand Down Expand Up @@ -1512,7 +1512,7 @@ def get_backup(

def update_backup(
self,
request: gsad_backup.UpdateBackupRequest = None,
request: Union[gsad_backup.UpdateBackupRequest, dict] = None,
*,
backup: gsad_backup.Backup = None,
update_mask: field_mask_pb2.FieldMask = None,
Expand All @@ -1524,7 +1524,7 @@ def update_backup(
[Backup][google.spanner.admin.database.v1.Backup].

Args:
request (google.cloud.spanner_admin_database_v1.types.UpdateBackupRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.UpdateBackupRequest, dict]):
The request object. The request for
[UpdateBackup][google.spanner.admin.database.v1.DatabaseAdmin.UpdateBackup].
backup (google.cloud.spanner_admin_database_v1.types.Backup):
Expand Down Expand Up @@ -1603,7 +1603,7 @@ def update_backup(

def delete_backup(
self,
request: backup.DeleteBackupRequest = None,
request: Union[backup.DeleteBackupRequest, dict] = None,
*,
name: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -1614,7 +1614,7 @@ def delete_backup(
[Backup][google.spanner.admin.database.v1.Backup].

Args:
request (google.cloud.spanner_admin_database_v1.types.DeleteBackupRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.DeleteBackupRequest, dict]):
The request object. The request for
[DeleteBackup][google.spanner.admin.database.v1.DatabaseAdmin.DeleteBackup].
name (str):
Expand Down Expand Up @@ -1669,7 +1669,7 @@ def delete_backup(

def list_backups(
self,
request: backup.ListBackupsRequest = None,
request: Union[backup.ListBackupsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -1681,7 +1681,7 @@ def list_backups(
the most recent ``create_time``.

Args:
request (google.cloud.spanner_admin_database_v1.types.ListBackupsRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.ListBackupsRequest, dict]):
The request object. The request for
[ListBackups][google.spanner.admin.database.v1.DatabaseAdmin.ListBackups].
parent (str):
Expand Down Expand Up @@ -1751,7 +1751,7 @@ def list_backups(

def restore_database(
self,
request: spanner_database_admin.RestoreDatabaseRequest = None,
request: Union[spanner_database_admin.RestoreDatabaseRequest, dict] = None,
*,
parent: str = None,
database_id: str = None,
Expand Down Expand Up @@ -1781,7 +1781,7 @@ def restore_database(
first restore to complete.

Args:
request (google.cloud.spanner_admin_database_v1.types.RestoreDatabaseRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.RestoreDatabaseRequest, dict]):
The request object. The request for
[RestoreDatabase][google.spanner.admin.database.v1.DatabaseAdmin.RestoreDatabase].
parent (str):
Expand Down Expand Up @@ -1878,7 +1878,9 @@ def restore_database(

def list_database_operations(
self,
request: spanner_database_admin.ListDatabaseOperationsRequest = None,
request: Union[
spanner_database_admin.ListDatabaseOperationsRequest, dict
] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -1897,7 +1899,7 @@ def list_database_operations(
operations.

Args:
request (google.cloud.spanner_admin_database_v1.types.ListDatabaseOperationsRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.ListDatabaseOperationsRequest, dict]):
The request object. The request for
[ListDatabaseOperations][google.spanner.admin.database.v1.DatabaseAdmin.ListDatabaseOperations].
parent (str):
Expand Down Expand Up @@ -1970,7 +1972,7 @@ def list_database_operations(

def list_backup_operations(
self,
request: backup.ListBackupOperationsRequest = None,
request: Union[backup.ListBackupOperationsRequest, dict] = None,
*,
parent: str = None,
retry: retries.Retry = gapic_v1.method.DEFAULT,
Expand All @@ -1991,7 +1993,7 @@ def list_backup_operations(
order starting from the most recently started operation.

Args:
request (google.cloud.spanner_admin_database_v1.types.ListBackupOperationsRequest):
request (Union[google.cloud.spanner_admin_database_v1.types.ListBackupOperationsRequest, dict]):
The request object. The request for
[ListBackupOperations][google.spanner.admin.database.v1.DatabaseAdmin.ListBackupOperations].
parent (str):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,16 +92,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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -139,16 +139,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.
Expand Down
Loading