chore: use gapic-generator-python 0.53.4 (#241)

- [ ] Regenerate this pull request now. docs: list oneofs in docstring fix(deps): require google-api-core >= 1.28.0 fix(deps): drop packaging dependency committer: busunkim96@ PiperOrigin-RevId: 406468269 Source-Link: googleapis/googleapis@83d81b0 Source-Link: https://github.com/googleapis/googleapis-gen/commit/2ff001fbacb9e77e71d734de5f955c05fdae8526 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMmZmMDAxZmJhY2I5ZTc3ZTcxZDczNGRlNWY5NTVjMDVmZGFlODUyNiJ9

Author: gcf-owl-bot[bot]

google/cloud/bigquery_datatransfer_v1/services/data_transfer_service/async_client.py

@@ -20,13 +20,15 @@
 import pkg_resources
 import warnings
 
-import google.api_core.client_options as ClientOptions # type: ignore
+from google.api_core.client_options import ClientOptions # type: ignore
 from google.api_core import exceptions as core_exceptions # type: ignore
 from google.api_core import gapic_v1 # type: ignore
 from google.api_core import retry as retries # type: ignore
 from google.auth import credentials as ga_credentials # type: ignore
 from google.oauth2 import service_account # type: ignore
 
+OptionalRetry = Union[retries.Retry, object]
+
 from google.cloud.bigquery_datatransfer_v1.services.data_transfer_service import pagers
 from google.cloud.bigquery_datatransfer_v1.types import datatransfer
 from google.cloud.bigquery_datatransfer_v1.types import transfer
@@ -183,18 +185,18 @@ def __init__(
 
  async def get_data_source(
  self,
- request: datatransfer.GetDataSourceRequest = None,
+ request: Union[datatransfer.GetDataSourceRequest, dict] = None,
  *,
  name: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> datatransfer.DataSource:
  r"""Retrieves a supported data source and returns its
  settings, which can be used for UI rendering.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.GetDataSourceRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.GetDataSourceRequest, dict]):
  The request object. A request to get data source info.
  name (:class:`str`):
  Required. The field will contain name of the resource
@@ -268,18 +270,18 @@ async def get_data_source(
 
  async def list_data_sources(
  self,
- request: datatransfer.ListDataSourcesRequest = None,
+ request: Union[datatransfer.ListDataSourcesRequest, dict] = None,
  *,
  parent: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListDataSourcesAsyncPager:
  r"""Lists supported data sources and returns their
  settings, which can be used for UI rendering.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.ListDataSourcesRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.ListDataSourcesRequest, dict]):
  The request object. Request to list supported data
  sources and their data transfer settings.
  parent (:class:`str`):
@@ -361,18 +363,18 @@ async def list_data_sources(
 
  async def create_transfer_config(
  self,
- request: datatransfer.CreateTransferConfigRequest = None,
+ request: Union[datatransfer.CreateTransferConfigRequest, dict] = None,
  *,
  parent: str = None,
  transfer_config: transfer.TransferConfig = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> transfer.TransferConfig:
  r"""Creates a new data transfer configuration.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.CreateTransferConfigRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.CreateTransferConfigRequest, dict]):
  The request object. A request to create a data transfer
  configuration. If new credentials are needed for this
  transfer configuration, an authorization code must be
@@ -458,19 +460,19 @@ async def create_transfer_config(
 
  async def update_transfer_config(
  self,
- request: datatransfer.UpdateTransferConfigRequest = None,
+ request: Union[datatransfer.UpdateTransferConfigRequest, dict] = None,
  *,
  transfer_config: transfer.TransferConfig = None,
  update_mask: field_mask_pb2.FieldMask = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> transfer.TransferConfig:
  r"""Updates a data transfer configuration.
  All fields must be set, even if they are not updated.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.UpdateTransferConfigRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.UpdateTransferConfigRequest, dict]):
  The request object. A request to update a transfer
  configuration. To update the user id of the transfer
  configuration, an authorization code needs to be
@@ -550,18 +552,18 @@ async def update_transfer_config(
 
  async def delete_transfer_config(
  self,
- request: datatransfer.DeleteTransferConfigRequest = None,
+ request: Union[datatransfer.DeleteTransferConfigRequest, dict] = None,
  *,
  name: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> None:
  r"""Deletes a data transfer configuration,
  including any associated transfer runs and logs.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.DeleteTransferConfigRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.DeleteTransferConfigRequest, dict]):
  The request object. A request to delete data transfer
  information. All associated transfer runs and log
  messages will be deleted as well.
@@ -628,17 +630,17 @@ async def delete_transfer_config(
 
  async def get_transfer_config(
  self,
- request: datatransfer.GetTransferConfigRequest = None,
+ request: Union[datatransfer.GetTransferConfigRequest, dict] = None,
  *,
  name: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> transfer.TransferConfig:
  r"""Returns information about a data transfer config.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.GetTransferConfigRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.GetTransferConfigRequest, dict]):
  The request object. A request to get data transfer
  information.
  name (:class:`str`):
@@ -717,18 +719,18 @@ async def get_transfer_config(
 
  async def list_transfer_configs(
  self,
- request: datatransfer.ListTransferConfigsRequest = None,
+ request: Union[datatransfer.ListTransferConfigsRequest, dict] = None,
  *,
  parent: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTransferConfigsAsyncPager:
  r"""Returns information about all transfer configs owned
  by a project in the specified location.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.ListTransferConfigsRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.ListTransferConfigsRequest, dict]):
  The request object. A request to list data transfers
  configured for a BigQuery project.
  parent (:class:`str`):
@@ -809,12 +811,12 @@ async def list_transfer_configs(
 
  async def schedule_transfer_runs(
  self,
- request: datatransfer.ScheduleTransferRunsRequest = None,
+ request: Union[datatransfer.ScheduleTransferRunsRequest, dict] = None,
  *,
  parent: str = None,
  start_time: timestamp_pb2.Timestamp = None,
  end_time: timestamp_pb2.Timestamp = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> datatransfer.ScheduleTransferRunsResponse:
@@ -825,7 +827,7 @@ async def schedule_transfer_runs(
  StartManualTransferRuns instead.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.ScheduleTransferRunsRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.ScheduleTransferRunsRequest, dict]):
  The request object. A request to schedule transfer runs
  for a time range.
  parent (:class:`str`):
@@ -910,9 +912,9 @@ async def schedule_transfer_runs(
 
  async def start_manual_transfer_runs(
  self,
- request: datatransfer.StartManualTransferRunsRequest = None,
+ request: Union[datatransfer.StartManualTransferRunsRequest, dict] = None,
  *,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> datatransfer.StartManualTransferRunsResponse:
@@ -922,7 +924,7 @@ async def start_manual_transfer_runs(
  and end_time (exclusive), or for a specific run_time.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.StartManualTransferRunsRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.StartManualTransferRunsRequest, dict]):
  The request object. A request to start manual transfer
  runs.
  retry (google.api_core.retry.Retry): Designation of what errors, if any,
@@ -962,18 +964,18 @@ async def start_manual_transfer_runs(
 
  async def get_transfer_run(
  self,
- request: datatransfer.GetTransferRunRequest = None,
+ request: Union[datatransfer.GetTransferRunRequest, dict] = None,
  *,
  name: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> transfer.TransferRun:
  r"""Returns information about the particular transfer
  run.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.GetTransferRunRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.GetTransferRunRequest, dict]):
  The request object. A request to get data transfer run
  information.
  name (:class:`str`):
@@ -1045,17 +1047,17 @@ async def get_transfer_run(
 
  async def delete_transfer_run(
  self,
- request: datatransfer.DeleteTransferRunRequest = None,
+ request: Union[datatransfer.DeleteTransferRunRequest, dict] = None,
  *,
  name: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> None:
  r"""Deletes the specified transfer run.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.DeleteTransferRunRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.DeleteTransferRunRequest, dict]):
  The request object. A request to delete data transfer
  run information.
  name (:class:`str`):
@@ -1122,17 +1124,17 @@ async def delete_transfer_run(
 
  async def list_transfer_runs(
  self,
- request: datatransfer.ListTransferRunsRequest = None,
+ request: Union[datatransfer.ListTransferRunsRequest, dict] = None,
  *,
  parent: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTransferRunsAsyncPager:
  r"""Returns information about running and completed jobs.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.ListTransferRunsRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.ListTransferRunsRequest, dict]):
  The request object. A request to list data transfer
  runs. UI can use this method to show/filter specific
  data transfer runs. The data source can use this method
@@ -1217,18 +1219,18 @@ async def list_transfer_runs(
 
  async def list_transfer_logs(
  self,
- request: datatransfer.ListTransferLogsRequest = None,
+ request: Union[datatransfer.ListTransferLogsRequest, dict] = None,
  *,
  parent: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> pagers.ListTransferLogsAsyncPager:
  r"""Returns user facing log messages for the data
  transfer run.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.ListTransferLogsRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.ListTransferLogsRequest, dict]):
  The request object. A request to get user facing log
  messages associated with data transfer run.
  parent (:class:`str`):
@@ -1310,10 +1312,10 @@ async def list_transfer_logs(
 
  async def check_valid_creds(
  self,
- request: datatransfer.CheckValidCredsRequest = None,
+ request: Union[datatransfer.CheckValidCredsRequest, dict] = None,
  *,
  name: str = None,
- retry: retries.Retry = gapic_v1.method.DEFAULT,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
  timeout: float = None,
  metadata: Sequence[Tuple[str, str]] = (),
  ) -> datatransfer.CheckValidCredsResponse:
@@ -1326,7 +1328,7 @@ async def check_valid_creds(
  can create a transfer config.
 
  Args:
- request (:class:`google.cloud.bigquery_datatransfer_v1.types.CheckValidCredsRequest`):
+ request (Union[google.cloud.bigquery_datatransfer_v1.types.CheckValidCredsRequest, dict]):
  The request object. A request to determine whether the
  user has valid credentials. This method is used to limit
  the number of OAuth popups in the user interface. The