feat: add default retry configuration (#123)

- [ ] Regenerate this pull request now. feat: add DeleteTransferJob operation feat: add AWS S3 compatible data source PiperOrigin-RevId: 473348271 Source-Link: googleapis/googleapis@56f2049 Source-Link: https://github.com/googleapis/googleapis-gen/commit/4f0ba4ff11c129006f76be68465f8e68a4a32814 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNGYwYmE0ZmYxMWMxMjkwMDZmNzZiZTY4NDY1ZjhlNjhhNGEzMjgxNCJ9

Author: gcf-owl-bot[bot]

google/cloud/storage_transfer/__init__.py

@@ -24,6 +24,7 @@
  CreateAgentPoolRequest,
  CreateTransferJobRequest,
  DeleteAgentPoolRequest,
+ DeleteTransferJobRequest,
  GetAgentPoolRequest,
  GetGoogleServiceAccountRequest,
  GetTransferJobRequest,
@@ -40,6 +41,7 @@
 from google.cloud.storage_transfer_v1.types.transfer_types import (
  AgentPool,
  AwsAccessKey,
+ AwsS3CompatibleData,
  AwsS3Data,
  AzureBlobStorageData,
  AzureCredentials,
@@ -53,6 +55,7 @@
  NotificationConfig,
  ObjectConditions,
  PosixFilesystem,
+ S3CompatibleMetadata,
  Schedule,
  TransferCounters,
  TransferJob,
@@ -68,6 +71,7 @@
  "CreateAgentPoolRequest",
  "CreateTransferJobRequest",
  "DeleteAgentPoolRequest",
+ "DeleteTransferJobRequest",
  "GetAgentPoolRequest",
  "GetGoogleServiceAccountRequest",
  "GetTransferJobRequest",
@@ -82,6 +86,7 @@
  "UpdateTransferJobRequest",
  "AgentPool",
  "AwsAccessKey",
+ "AwsS3CompatibleData",
  "AwsS3Data",
  "AzureBlobStorageData",
  "AzureCredentials",
@@ -95,6 +100,7 @@
  "NotificationConfig",
  "ObjectConditions",
  "PosixFilesystem",
+ "S3CompatibleMetadata",
  "Schedule",
  "TransferCounters",
  "TransferJob",

google/cloud/storage_transfer_v1/__init__.py

@@ -22,6 +22,7 @@
  CreateAgentPoolRequest,
  CreateTransferJobRequest,
  DeleteAgentPoolRequest,
+ DeleteTransferJobRequest,
  GetAgentPoolRequest,
  GetGoogleServiceAccountRequest,
  GetTransferJobRequest,
@@ -38,6 +39,7 @@
 from .types.transfer_types import (
  AgentPool,
  AwsAccessKey,
+ AwsS3CompatibleData,
  AwsS3Data,
  AzureBlobStorageData,
  AzureCredentials,
@@ -51,6 +53,7 @@
  NotificationConfig,
  ObjectConditions,
  PosixFilesystem,
+ S3CompatibleMetadata,
  Schedule,
  TransferCounters,
  TransferJob,
@@ -64,12 +67,14 @@
  "StorageTransferServiceAsyncClient",
  "AgentPool",
  "AwsAccessKey",
+ "AwsS3CompatibleData",
  "AwsS3Data",
  "AzureBlobStorageData",
  "AzureCredentials",
  "CreateAgentPoolRequest",
  "CreateTransferJobRequest",
  "DeleteAgentPoolRequest",
+ "DeleteTransferJobRequest",
  "ErrorLogEntry",
  "ErrorSummary",
  "GcsData",
@@ -90,6 +95,7 @@
  "PosixFilesystem",
  "ResumeTransferOperationRequest",
  "RunTransferJobRequest",
+ "S3CompatibleMetadata",
  "Schedule",
  "StorageTransferServiceClient",
  "TransferCounters",

google/cloud/storage_transfer_v1/gapic_metadata.json

@@ -25,6 +25,11 @@
  "delete_agent_pool"
  ]
  },
+ "DeleteTransferJob": {
+ "methods": [
+ "delete_transfer_job"
+ ]
+ },
  "GetAgentPool": {
  "methods": [
  "get_agent_pool"
@@ -95,6 +100,11 @@
  "delete_agent_pool"
  ]
  },
+ "DeleteTransferJob": {
+ "methods": [
+ "delete_transfer_job"
+ ]
+ },
  "GetAgentPool": {
  "methods": [
  "get_agent_pool"

google/cloud/storage_transfer_v1/services/storage_transfer_service/async_client.py

@@ -364,7 +364,7 @@ async def sample_create_transfer_job():
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.create_transfer_job,
- default_timeout=None,
+ default_timeout=60.0,
  client_info=DEFAULT_CLIENT_INFO,
  )
 
@@ -880,6 +880,76 @@ async def sample_run_transfer_job():
  # Done; return the response.
  return response
 
+ async def delete_transfer_job(
+ self,
+ request: Union[transfer.DeleteTransferJobRequest, dict] = None,
+ *,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
+ timeout: float = None,
+ metadata: Sequence[Tuple[str, str]] = (),
+ ) -> None:
+ r"""Deletes a transfer job. Deleting a transfer job sets its status
+ to
+ [DELETED][google.storagetransfer.v1.TransferJob.Status.DELETED].
+
+ .. code-block:: python
+
+ # This snippet has been automatically generated and should be regarded as a
+ # code template only.
+ # It will require modifications to work:
+ # - It may require correct/in-range values for request initialization.
+ # - It may require specifying regional endpoints when creating the service
+ # client as shown in:
+ # https://googleapis.dev/python/google-api-core/latest/client_options.html
+ from google.cloud import storage_transfer_v1
+
+ async def sample_delete_transfer_job():
+ # Create a client
+ client = storage_transfer_v1.StorageTransferServiceAsyncClient()
+
+ # Initialize request argument(s)
+ request = storage_transfer_v1.DeleteTransferJobRequest(
+ job_name="job_name_value",
+ project_id="project_id_value",
+ )
+
+ # Make the request
+ await client.delete_transfer_job(request=request)
+
+ Args:
+ request (Union[google.cloud.storage_transfer_v1.types.DeleteTransferJobRequest, dict]):
+ The request object. Request passed to DeleteTransferJob.
+ retry (google.api_core.retry.Retry): Designation of what errors, if any,
+ should be retried.
+ timeout (float): The timeout for this request.
+ metadata (Sequence[Tuple[str, str]]): Strings which should be
+ sent along with the request as metadata.
+ """
+ # Create or coerce a protobuf request object.
+ request = transfer.DeleteTransferJobRequest(request)
+
+ # Wrap the RPC method; this adds retry and timeout information,
+ # and friendly error handling.
+ rpc = gapic_v1.method_async.wrap_method(
+ self._client._transport.delete_transfer_job,
+ default_timeout=None,
+ client_info=DEFAULT_CLIENT_INFO,
+ )
+
+ # Certain fields should be provided within the metadata header;
+ # add these here.
+ metadata = tuple(metadata) + (
+ gapic_v1.routing_header.to_grpc_metadata((("job_name", request.job_name),)),
+ )
+
+ # Send the request.
+ await rpc(
+ request,
+ retry=retry,
+ timeout=timeout,
+ metadata=metadata,
+ )
+
  async def create_agent_pool(
  self,
  request: Union[transfer.CreateAgentPoolRequest, dict] = None,

google/cloud/storage_transfer_v1/services/storage_transfer_service/client.py

@@ -1109,6 +1109,77 @@ def sample_run_transfer_job():
  # Done; return the response.
  return response
 
+ def delete_transfer_job(
+ self,
+ request: Union[transfer.DeleteTransferJobRequest, dict] = None,
+ *,
+ retry: OptionalRetry = gapic_v1.method.DEFAULT,
+ timeout: float = None,
+ metadata: Sequence[Tuple[str, str]] = (),
+ ) -> None:
+ r"""Deletes a transfer job. Deleting a transfer job sets its status
+ to
+ [DELETED][google.storagetransfer.v1.TransferJob.Status.DELETED].
+
+ .. code-block:: python
+
+ # This snippet has been automatically generated and should be regarded as a
+ # code template only.
+ # It will require modifications to work:
+ # - It may require correct/in-range values for request initialization.
+ # - It may require specifying regional endpoints when creating the service
+ # client as shown in:
+ # https://googleapis.dev/python/google-api-core/latest/client_options.html
+ from google.cloud import storage_transfer_v1
+
+ def sample_delete_transfer_job():
+ # Create a client
+ client = storage_transfer_v1.StorageTransferServiceClient()
+
+ # Initialize request argument(s)
+ request = storage_transfer_v1.DeleteTransferJobRequest(
+ job_name="job_name_value",
+ project_id="project_id_value",
+ )
+
+ # Make the request
+ client.delete_transfer_job(request=request)
+
+ Args:
+ request (Union[google.cloud.storage_transfer_v1.types.DeleteTransferJobRequest, dict]):
+ The request object. Request passed to DeleteTransferJob.
+ retry (google.api_core.retry.Retry): Designation of what errors, if any,
+ should be retried.
+ timeout (float): The timeout for this request.
+ metadata (Sequence[Tuple[str, str]]): Strings which should be
+ sent along with the request as metadata.
+ """
+ # Create or coerce a protobuf request object.
+ # Minor optimization to avoid making a copy if the user passes
+ # in a transfer.DeleteTransferJobRequest.
+ # There's no risk of modifying the input as we've already verified
+ # there are no flattened fields.
+ if not isinstance(request, transfer.DeleteTransferJobRequest):
+ request = transfer.DeleteTransferJobRequest(request)
+
+ # Wrap the RPC method; this adds retry and timeout information,
+ # and friendly error handling.
+ rpc = self._transport._wrapped_methods[self._transport.delete_transfer_job]
+
+ # Certain fields should be provided within the metadata header;
+ # add these here.
+ metadata = tuple(metadata) + (
+ gapic_v1.routing_header.to_grpc_metadata((("job_name", request.job_name),)),
+ )
+
+ # Send the request.
+ rpc(
+ request,
+ retry=retry,
+ timeout=timeout,
+ metadata=metadata,
+ )
+
  def create_agent_pool(
  self,
  request: Union[transfer.CreateAgentPoolRequest, dict] = None,

google/cloud/storage_transfer_v1/services/storage_transfer_service/transports/base.py

@@ -136,7 +136,7 @@ def _prep_wrapped_messages(self, client_info):
  ),
  self.create_transfer_job: gapic_v1.method.wrap_method(
  self.create_transfer_job,
- default_timeout=None,
+ default_timeout=60.0,
  client_info=client_info,
  ),
  self.update_transfer_job: gapic_v1.method.wrap_method(
@@ -169,6 +169,11 @@ def _prep_wrapped_messages(self, client_info):
  default_timeout=None,
  client_info=client_info,
  ),
+ self.delete_transfer_job: gapic_v1.method.wrap_method(
+ self.delete_transfer_job,
+ default_timeout=None,
+ client_info=client_info,
+ ),
  self.create_agent_pool: gapic_v1.method.wrap_method(
  self.create_agent_pool,
  default_timeout=None,
@@ -288,6 +293,15 @@ def run_transfer_job(
  ]:
  raise NotImplementedError()
 
+ @property
+ def delete_transfer_job(
+ self,
+ ) -> Callable[
+ [transfer.DeleteTransferJobRequest],
+ Union[empty_pb2.Empty, Awaitable[empty_pb2.Empty]],
+ ]:
+ raise NotImplementedError()
+
  @property
  def create_agent_pool(
  self,

google/cloud/storage_transfer_v1/services/storage_transfer_service/transports/grpc.py

@@ -482,6 +482,34 @@ def run_transfer_job(
  )
  return self._stubs["run_transfer_job"]
 
+ @property
+ def delete_transfer_job(
+ self,
+ ) -> Callable[[transfer.DeleteTransferJobRequest], empty_pb2.Empty]:
+ r"""Return a callable for the delete transfer job method over gRPC.
+
+ Deletes a transfer job. Deleting a transfer job sets its status
+ to
+ [DELETED][google.storagetransfer.v1.TransferJob.Status.DELETED].
+
+ Returns:
+ Callable[[~.DeleteTransferJobRequest],
+ ~.Empty]:
+ A function that, when called, will call the underlying RPC
+ on the server.
+ """
+ # Generate a "stub function" on-the-fly which will actually make
+ # the request.
+ # gRPC handles serialization and deserialization, so we just need
+ # to pass in the functions for each.
+ if "delete_transfer_job" not in self._stubs:
+ self._stubs["delete_transfer_job"] = self.grpc_channel.unary_unary(
+ "/google.storagetransfer.v1.StorageTransferService/DeleteTransferJob",
+ request_serializer=transfer.DeleteTransferJobRequest.serialize,
+ response_deserializer=empty_pb2.Empty.FromString,
+ )
+ return self._stubs["delete_transfer_job"]
+
  @property
  def create_agent_pool(
  self,

google/cloud/storage_transfer_v1/services/storage_transfer_service/transports/grpc_asyncio.py

@@ -498,6 +498,34 @@ def run_transfer_job(
  )
  return self._stubs["run_transfer_job"]
 
+ @property
+ def delete_transfer_job(
+ self,
+ ) -> Callable[[transfer.DeleteTransferJobRequest], Awaitable[empty_pb2.Empty]]:
+ r"""Return a callable for the delete transfer job method over gRPC.
+
+ Deletes a transfer job. Deleting a transfer job sets its status
+ to
+ [DELETED][google.storagetransfer.v1.TransferJob.Status.DELETED].
+
+ Returns:
+ Callable[[~.DeleteTransferJobRequest],
+ Awaitable[~.Empty]]:
+ A function that, when called, will call the underlying RPC
+ on the server.
+ """
+ # Generate a "stub function" on-the-fly which will actually make
+ # the request.
+ # gRPC handles serialization and deserialization, so we just need
+ # to pass in the functions for each.
+ if "delete_transfer_job" not in self._stubs:
+ self._stubs["delete_transfer_job"] = self.grpc_channel.unary_unary(
+ "/google.storagetransfer.v1.StorageTransferService/DeleteTransferJob",
+ request_serializer=transfer.DeleteTransferJobRequest.serialize,
+ response_deserializer=empty_pb2.Empty.FromString,
+ )
+ return self._stubs["delete_transfer_job"]
+
  @property
  def create_agent_pool(
  self,