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