chore: use gapic-generator-python 0.51.2 (#165)

- [ ] Regenerate this pull request now.

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

Committer: @busunkim96
PiperOrigin-RevId: 398509016

Source-Link: googleapis/googleapis@b224dfa

Source-Link: googleapis/googleapis-gen@63a1db7
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9

google/cloud/tasks_v2/services/cloud_tasks/client.py

@@ -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
@@ -378,7 +378,7 @@ def __init__(
 
     def list_queues(
         self,
-        request: cloudtasks.ListQueuesRequest = None,
+        request: Union[cloudtasks.ListQueuesRequest, dict] = None,
         *,
         parent: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -389,7 +389,7 @@ def list_queues(
         Queues are returned in lexicographical order.
 
         Args:
-            request (google.cloud.tasks_v2.types.ListQueuesRequest):
+            request (Union[google.cloud.tasks_v2.types.ListQueuesRequest, dict]):
                 The request object. Request message for
                 [ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues].
             parent (str):
@@ -459,7 +459,7 @@ def list_queues(
 
     def get_queue(
         self,
-        request: cloudtasks.GetQueueRequest = None,
+        request: Union[cloudtasks.GetQueueRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -469,7 +469,7 @@ def get_queue(
         r"""Gets a queue.
 
         Args:
-            request (google.cloud.tasks_v2.types.GetQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.GetQueueRequest, dict]):
                 The request object. Request message for
                 [GetQueue][google.cloud.tasks.v2.CloudTasks.GetQueue].
             name (str):
@@ -534,7 +534,7 @@ def get_queue(
 
     def create_queue(
         self,
-        request: cloudtasks.CreateQueueRequest = None,
+        request: Union[cloudtasks.CreateQueueRequest, dict] = None,
         *,
         parent: str = None,
         queue: gct_queue.Queue = None,
@@ -555,7 +555,7 @@ def create_queue(
         before using this method.
 
         Args:
-            request (google.cloud.tasks_v2.types.CreateQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.CreateQueueRequest, dict]):
                 The request object. Request message for
                 [CreateQueue][google.cloud.tasks.v2.CloudTasks.CreateQueue].
             parent (str):
@@ -636,7 +636,7 @@ def create_queue(
 
     def update_queue(
         self,
-        request: cloudtasks.UpdateQueueRequest = None,
+        request: Union[cloudtasks.UpdateQueueRequest, dict] = None,
         *,
         queue: gct_queue.Queue = None,
         update_mask: field_mask_pb2.FieldMask = None,
@@ -660,7 +660,7 @@ def update_queue(
         before using this method.
 
         Args:
-            request (google.cloud.tasks_v2.types.UpdateQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.UpdateQueueRequest, dict]):
                 The request object. Request message for
                 [UpdateQueue][google.cloud.tasks.v2.CloudTasks.UpdateQueue].
             queue (google.cloud.tasks_v2.types.Queue):
@@ -746,7 +746,7 @@ def update_queue(
 
     def delete_queue(
         self,
-        request: cloudtasks.DeleteQueueRequest = None,
+        request: Union[cloudtasks.DeleteQueueRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -767,7 +767,7 @@ def delete_queue(
         before using this method.
 
         Args:
-            request (google.cloud.tasks_v2.types.DeleteQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.DeleteQueueRequest, dict]):
                 The request object. Request message for
                 [DeleteQueue][google.cloud.tasks.v2.CloudTasks.DeleteQueue].
             name (str):
@@ -821,7 +821,7 @@ def delete_queue(
 
     def purge_queue(
         self,
-        request: cloudtasks.PurgeQueueRequest = None,
+        request: Union[cloudtasks.PurgeQueueRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -836,7 +836,7 @@ def purge_queue(
         effect. A purge is irreversible.
 
         Args:
-            request (google.cloud.tasks_v2.types.PurgeQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.PurgeQueueRequest, dict]):
                 The request object. Request message for
                 [PurgeQueue][google.cloud.tasks.v2.CloudTasks.PurgeQueue].
             name (str):
@@ -901,7 +901,7 @@ def purge_queue(
 
     def pause_queue(
         self,
-        request: cloudtasks.PauseQueueRequest = None,
+        request: Union[cloudtasks.PauseQueueRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -918,7 +918,7 @@ def pause_queue(
         [PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED].
 
         Args:
-            request (google.cloud.tasks_v2.types.PauseQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.PauseQueueRequest, dict]):
                 The request object. Request message for
                 [PauseQueue][google.cloud.tasks.v2.CloudTasks.PauseQueue].
             name (str):
@@ -983,7 +983,7 @@ def pause_queue(
 
     def resume_queue(
         self,
-        request: cloudtasks.ResumeQueueRequest = None,
+        request: Union[cloudtasks.ResumeQueueRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1007,7 +1007,7 @@ def resume_queue(
         Risks <https://cloud.google.com/tasks/docs/manage-cloud-task-scaling>`__.
 
         Args:
-            request (google.cloud.tasks_v2.types.ResumeQueueRequest):
+            request (Union[google.cloud.tasks_v2.types.ResumeQueueRequest, dict]):
                 The request object. Request message for
                 [ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue].
             name (str):
@@ -1072,7 +1072,7 @@ def resume_queue(
 
     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,
@@ -1090,7 +1090,7 @@ def get_iam_policy(
         -  ``cloudtasks.queues.getIamPolicy``
 
         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):
@@ -1205,7 +1205,7 @@ def get_iam_policy(
 
     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,
@@ -1227,7 +1227,7 @@ def set_iam_policy(
         -  ``cloudtasks.queues.setIamPolicy``
 
         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):
@@ -1342,7 +1342,7 @@ def set_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,
@@ -1361,7 +1361,7 @@ def test_iam_permissions(
         warning.
 
         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):
@@ -1432,7 +1432,7 @@ def test_iam_permissions(
 
     def list_tasks(
         self,
-        request: cloudtasks.ListTasksRequest = None,
+        request: Union[cloudtasks.ListTasksRequest, dict] = None,
         *,
         parent: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1451,7 +1451,7 @@ def list_tasks(
         at any time.
 
         Args:
-            request (google.cloud.tasks_v2.types.ListTasksRequest):
+            request (Union[google.cloud.tasks_v2.types.ListTasksRequest, dict]):
                 The request object. Request message for listing tasks
                 using
                 [ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks].
@@ -1522,7 +1522,7 @@ def list_tasks(
 
     def get_task(
         self,
-        request: cloudtasks.GetTaskRequest = None,
+        request: Union[cloudtasks.GetTaskRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1532,7 +1532,7 @@ def get_task(
         r"""Gets a task.
 
         Args:
-            request (google.cloud.tasks_v2.types.GetTaskRequest):
+            request (Union[google.cloud.tasks_v2.types.GetTaskRequest, dict]):
                 The request object. Request message for getting a task
                 using
                 [GetTask][google.cloud.tasks.v2.CloudTasks.GetTask].
@@ -1592,7 +1592,7 @@ def get_task(
 
     def create_task(
         self,
-        request: cloudtasks.CreateTaskRequest = None,
+        request: Union[cloudtasks.CreateTaskRequest, dict] = None,
         *,
         parent: str = None,
         task: gct_task.Task = None,
@@ -1608,7 +1608,7 @@ def create_task(
         -  The maximum task size is 100KB.
 
         Args:
-            request (google.cloud.tasks_v2.types.CreateTaskRequest):
+            request (Union[google.cloud.tasks_v2.types.CreateTaskRequest, dict]):
                 The request object. Request message for
                 [CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask].
             parent (str):
@@ -1717,7 +1717,7 @@ def create_task(
 
     def delete_task(
         self,
-        request: cloudtasks.DeleteTaskRequest = None,
+        request: Union[cloudtasks.DeleteTaskRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1730,7 +1730,7 @@ def delete_task(
         or permanently failed.
 
         Args:
-            request (google.cloud.tasks_v2.types.DeleteTaskRequest):
+            request (Union[google.cloud.tasks_v2.types.DeleteTaskRequest, dict]):
                 The request object. Request message for deleting a task
                 using
                 [DeleteTask][google.cloud.tasks.v2.CloudTasks.DeleteTask].
@@ -1785,7 +1785,7 @@ def delete_task(
 
     def run_task(
         self,
-        request: cloudtasks.RunTaskRequest = None,
+        request: Union[cloudtasks.RunTaskRequest, dict] = None,
         *,
         name: str = None,
         retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1821,7 +1821,7 @@ def run_task(
         task that has already succeeded or permanently failed.
 
         Args:
-            request (google.cloud.tasks_v2.types.RunTaskRequest):
+            request (Union[google.cloud.tasks_v2.types.RunTaskRequest, dict]):
                 The request object. Request message for forcing a task
                 to run now using
                 [RunTask][google.cloud.tasks.v2.CloudTasks.RunTask].

google/cloud/tasks_v2/services/cloud_tasks/transports/base.py

@@ -122,7 +122,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)

google/cloud/tasks_v2/services/cloud_tasks/transports/grpc.py

@@ -88,16 +88,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.

google/cloud/tasks_v2/services/cloud_tasks/transports/grpc_asyncio.py

@@ -135,16 +135,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.