Skip to content
This repository was archived by the owner on Feb 1, 2024. It is now read-only.

Commit 42d768b

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
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: https://github.com/googleapis/googleapis-gen/commit/63a1db7a38d74b9639592f521ed1daaf7299ad9a Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNjNhMWRiN2EzOGQ3NGI5NjM5NTkyZjUyMWVkMWRhYWY3Mjk5YWQ5YSJ9
1 parent a5bfac9 commit 42d768b

File tree

15 files changed

+183
-183
lines changed

15 files changed

+183
-183
lines changed

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

Lines changed: 33 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
from distutils import util
1818
import os
1919
import re
20-
from typing import Callable, Dict, Optional, Sequence, Tuple, Type, Union
20+
from typing import Dict, Optional, Sequence, Tuple, Type, Union
2121
import pkg_resources
2222

2323
from google.api_core import client_options as client_options_lib # type: ignore
@@ -378,7 +378,7 @@ def __init__(
378378

379379
def list_queues(
380380
self,
381-
request: cloudtasks.ListQueuesRequest = None,
381+
request: Union[cloudtasks.ListQueuesRequest, dict] = None,
382382
*,
383383
parent: str = None,
384384
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -389,7 +389,7 @@ def list_queues(
389389
Queues are returned in lexicographical order.
390390
391391
Args:
392-
request (google.cloud.tasks_v2.types.ListQueuesRequest):
392+
request (Union[google.cloud.tasks_v2.types.ListQueuesRequest, dict]):
393393
The request object. Request message for
394394
[ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues].
395395
parent (str):
@@ -459,7 +459,7 @@ def list_queues(
459459

460460
def get_queue(
461461
self,
462-
request: cloudtasks.GetQueueRequest = None,
462+
request: Union[cloudtasks.GetQueueRequest, dict] = None,
463463
*,
464464
name: str = None,
465465
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -469,7 +469,7 @@ def get_queue(
469469
r"""Gets a queue.
470470
471471
Args:
472-
request (google.cloud.tasks_v2.types.GetQueueRequest):
472+
request (Union[google.cloud.tasks_v2.types.GetQueueRequest, dict]):
473473
The request object. Request message for
474474
[GetQueue][google.cloud.tasks.v2.CloudTasks.GetQueue].
475475
name (str):
@@ -534,7 +534,7 @@ def get_queue(
534534

535535
def create_queue(
536536
self,
537-
request: cloudtasks.CreateQueueRequest = None,
537+
request: Union[cloudtasks.CreateQueueRequest, dict] = None,
538538
*,
539539
parent: str = None,
540540
queue: gct_queue.Queue = None,
@@ -555,7 +555,7 @@ def create_queue(
555555
before using this method.
556556
557557
Args:
558-
request (google.cloud.tasks_v2.types.CreateQueueRequest):
558+
request (Union[google.cloud.tasks_v2.types.CreateQueueRequest, dict]):
559559
The request object. Request message for
560560
[CreateQueue][google.cloud.tasks.v2.CloudTasks.CreateQueue].
561561
parent (str):
@@ -636,7 +636,7 @@ def create_queue(
636636

637637
def update_queue(
638638
self,
639-
request: cloudtasks.UpdateQueueRequest = None,
639+
request: Union[cloudtasks.UpdateQueueRequest, dict] = None,
640640
*,
641641
queue: gct_queue.Queue = None,
642642
update_mask: field_mask_pb2.FieldMask = None,
@@ -660,7 +660,7 @@ def update_queue(
660660
before using this method.
661661
662662
Args:
663-
request (google.cloud.tasks_v2.types.UpdateQueueRequest):
663+
request (Union[google.cloud.tasks_v2.types.UpdateQueueRequest, dict]):
664664
The request object. Request message for
665665
[UpdateQueue][google.cloud.tasks.v2.CloudTasks.UpdateQueue].
666666
queue (google.cloud.tasks_v2.types.Queue):
@@ -746,7 +746,7 @@ def update_queue(
746746

747747
def delete_queue(
748748
self,
749-
request: cloudtasks.DeleteQueueRequest = None,
749+
request: Union[cloudtasks.DeleteQueueRequest, dict] = None,
750750
*,
751751
name: str = None,
752752
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -767,7 +767,7 @@ def delete_queue(
767767
before using this method.
768768
769769
Args:
770-
request (google.cloud.tasks_v2.types.DeleteQueueRequest):
770+
request (Union[google.cloud.tasks_v2.types.DeleteQueueRequest, dict]):
771771
The request object. Request message for
772772
[DeleteQueue][google.cloud.tasks.v2.CloudTasks.DeleteQueue].
773773
name (str):
@@ -821,7 +821,7 @@ def delete_queue(
821821

822822
def purge_queue(
823823
self,
824-
request: cloudtasks.PurgeQueueRequest = None,
824+
request: Union[cloudtasks.PurgeQueueRequest, dict] = None,
825825
*,
826826
name: str = None,
827827
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -836,7 +836,7 @@ def purge_queue(
836836
effect. A purge is irreversible.
837837
838838
Args:
839-
request (google.cloud.tasks_v2.types.PurgeQueueRequest):
839+
request (Union[google.cloud.tasks_v2.types.PurgeQueueRequest, dict]):
840840
The request object. Request message for
841841
[PurgeQueue][google.cloud.tasks.v2.CloudTasks.PurgeQueue].
842842
name (str):
@@ -901,7 +901,7 @@ def purge_queue(
901901

902902
def pause_queue(
903903
self,
904-
request: cloudtasks.PauseQueueRequest = None,
904+
request: Union[cloudtasks.PauseQueueRequest, dict] = None,
905905
*,
906906
name: str = None,
907907
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -918,7 +918,7 @@ def pause_queue(
918918
[PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED].
919919
920920
Args:
921-
request (google.cloud.tasks_v2.types.PauseQueueRequest):
921+
request (Union[google.cloud.tasks_v2.types.PauseQueueRequest, dict]):
922922
The request object. Request message for
923923
[PauseQueue][google.cloud.tasks.v2.CloudTasks.PauseQueue].
924924
name (str):
@@ -983,7 +983,7 @@ def pause_queue(
983983

984984
def resume_queue(
985985
self,
986-
request: cloudtasks.ResumeQueueRequest = None,
986+
request: Union[cloudtasks.ResumeQueueRequest, dict] = None,
987987
*,
988988
name: str = None,
989989
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1007,7 +1007,7 @@ def resume_queue(
10071007
Risks <https://cloud.google.com/tasks/docs/manage-cloud-task-scaling>`__.
10081008
10091009
Args:
1010-
request (google.cloud.tasks_v2.types.ResumeQueueRequest):
1010+
request (Union[google.cloud.tasks_v2.types.ResumeQueueRequest, dict]):
10111011
The request object. Request message for
10121012
[ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue].
10131013
name (str):
@@ -1072,7 +1072,7 @@ def resume_queue(
10721072

10731073
def get_iam_policy(
10741074
self,
1075-
request: iam_policy_pb2.GetIamPolicyRequest = None,
1075+
request: Union[iam_policy_pb2.GetIamPolicyRequest, dict] = None,
10761076
*,
10771077
resource: str = None,
10781078
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1090,7 +1090,7 @@ def get_iam_policy(
10901090
- ``cloudtasks.queues.getIamPolicy``
10911091
10921092
Args:
1093-
request (google.iam.v1.iam_policy_pb2.GetIamPolicyRequest):
1093+
request (Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]):
10941094
The request object. Request message for `GetIamPolicy`
10951095
method.
10961096
resource (str):
@@ -1205,7 +1205,7 @@ def get_iam_policy(
12051205

12061206
def set_iam_policy(
12071207
self,
1208-
request: iam_policy_pb2.SetIamPolicyRequest = None,
1208+
request: Union[iam_policy_pb2.SetIamPolicyRequest, dict] = None,
12091209
*,
12101210
resource: str = None,
12111211
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1227,7 +1227,7 @@ def set_iam_policy(
12271227
- ``cloudtasks.queues.setIamPolicy``
12281228
12291229
Args:
1230-
request (google.iam.v1.iam_policy_pb2.SetIamPolicyRequest):
1230+
request (Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]):
12311231
The request object. Request message for `SetIamPolicy`
12321232
method.
12331233
resource (str):
@@ -1342,7 +1342,7 @@ def set_iam_policy(
13421342

13431343
def test_iam_permissions(
13441344
self,
1345-
request: iam_policy_pb2.TestIamPermissionsRequest = None,
1345+
request: Union[iam_policy_pb2.TestIamPermissionsRequest, dict] = None,
13461346
*,
13471347
resource: str = None,
13481348
permissions: Sequence[str] = None,
@@ -1361,7 +1361,7 @@ def test_iam_permissions(
13611361
warning.
13621362
13631363
Args:
1364-
request (google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest):
1364+
request (Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]):
13651365
The request object. Request message for
13661366
`TestIamPermissions` method.
13671367
resource (str):
@@ -1432,7 +1432,7 @@ def test_iam_permissions(
14321432

14331433
def list_tasks(
14341434
self,
1435-
request: cloudtasks.ListTasksRequest = None,
1435+
request: Union[cloudtasks.ListTasksRequest, dict] = None,
14361436
*,
14371437
parent: str = None,
14381438
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1451,7 +1451,7 @@ def list_tasks(
14511451
at any time.
14521452
14531453
Args:
1454-
request (google.cloud.tasks_v2.types.ListTasksRequest):
1454+
request (Union[google.cloud.tasks_v2.types.ListTasksRequest, dict]):
14551455
The request object. Request message for listing tasks
14561456
using
14571457
[ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks].
@@ -1522,7 +1522,7 @@ def list_tasks(
15221522

15231523
def get_task(
15241524
self,
1525-
request: cloudtasks.GetTaskRequest = None,
1525+
request: Union[cloudtasks.GetTaskRequest, dict] = None,
15261526
*,
15271527
name: str = None,
15281528
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1532,7 +1532,7 @@ def get_task(
15321532
r"""Gets a task.
15331533
15341534
Args:
1535-
request (google.cloud.tasks_v2.types.GetTaskRequest):
1535+
request (Union[google.cloud.tasks_v2.types.GetTaskRequest, dict]):
15361536
The request object. Request message for getting a task
15371537
using
15381538
[GetTask][google.cloud.tasks.v2.CloudTasks.GetTask].
@@ -1592,7 +1592,7 @@ def get_task(
15921592

15931593
def create_task(
15941594
self,
1595-
request: cloudtasks.CreateTaskRequest = None,
1595+
request: Union[cloudtasks.CreateTaskRequest, dict] = None,
15961596
*,
15971597
parent: str = None,
15981598
task: gct_task.Task = None,
@@ -1608,7 +1608,7 @@ def create_task(
16081608
- The maximum task size is 100KB.
16091609
16101610
Args:
1611-
request (google.cloud.tasks_v2.types.CreateTaskRequest):
1611+
request (Union[google.cloud.tasks_v2.types.CreateTaskRequest, dict]):
16121612
The request object. Request message for
16131613
[CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask].
16141614
parent (str):
@@ -1717,7 +1717,7 @@ def create_task(
17171717

17181718
def delete_task(
17191719
self,
1720-
request: cloudtasks.DeleteTaskRequest = None,
1720+
request: Union[cloudtasks.DeleteTaskRequest, dict] = None,
17211721
*,
17221722
name: str = None,
17231723
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1730,7 +1730,7 @@ def delete_task(
17301730
or permanently failed.
17311731
17321732
Args:
1733-
request (google.cloud.tasks_v2.types.DeleteTaskRequest):
1733+
request (Union[google.cloud.tasks_v2.types.DeleteTaskRequest, dict]):
17341734
The request object. Request message for deleting a task
17351735
using
17361736
[DeleteTask][google.cloud.tasks.v2.CloudTasks.DeleteTask].
@@ -1785,7 +1785,7 @@ def delete_task(
17851785

17861786
def run_task(
17871787
self,
1788-
request: cloudtasks.RunTaskRequest = None,
1788+
request: Union[cloudtasks.RunTaskRequest, dict] = None,
17891789
*,
17901790
name: str = None,
17911791
retry: retries.Retry = gapic_v1.method.DEFAULT,
@@ -1821,7 +1821,7 @@ def run_task(
18211821
task that has already succeeded or permanently failed.
18221822
18231823
Args:
1824-
request (google.cloud.tasks_v2.types.RunTaskRequest):
1824+
request (Union[google.cloud.tasks_v2.types.RunTaskRequest, dict]):
18251825
The request object. Request message for forcing a task
18261826
to run now using
18271827
[RunTask][google.cloud.tasks.v2.CloudTasks.RunTask].

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ def __init__(
122122
**scopes_kwargs, quota_project_id=quota_project_id
123123
)
124124

125-
# If the credentials is service account credentials, then always try to use self signed JWT.
125+
# If the credentials are service account credentials, then always try to use self signed JWT.
126126
if (
127127
always_use_jwt_access
128128
and isinstance(credentials, service_account.Credentials)

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -88,16 +88,16 @@ def __init__(
8888
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
8989
If provided, it overrides the ``host`` argument and tries to create
9090
a mutual TLS channel with client SSL credentials from
91-
``client_cert_source`` or applicatin default SSL credentials.
91+
``client_cert_source`` or application default SSL credentials.
9292
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
9393
Deprecated. A callback to provide client SSL certificate bytes and
9494
private key bytes, both in PEM format. It is ignored if
9595
``api_mtls_endpoint`` is None.
9696
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
97-
for grpc channel. It is ignored if ``channel`` is provided.
97+
for the grpc channel. It is ignored if ``channel`` is provided.
9898
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
9999
A callback to provide client certificate bytes and private key bytes,
100-
both in PEM format. It is used to configure mutual TLS channel. It is
100+
both in PEM format. It is used to configure a mutual TLS channel. It is
101101
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
102102
quota_project_id (Optional[str]): An optional project to use for billing
103103
and quota.

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -135,16 +135,16 @@ def __init__(
135135
api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
136136
If provided, it overrides the ``host`` argument and tries to create
137137
a mutual TLS channel with client SSL credentials from
138-
``client_cert_source`` or applicatin default SSL credentials.
138+
``client_cert_source`` or application default SSL credentials.
139139
client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
140140
Deprecated. A callback to provide client SSL certificate bytes and
141141
private key bytes, both in PEM format. It is ignored if
142142
``api_mtls_endpoint`` is None.
143143
ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
144-
for grpc channel. It is ignored if ``channel`` is provided.
144+
for the grpc channel. It is ignored if ``channel`` is provided.
145145
client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
146146
A callback to provide client certificate bytes and private key bytes,
147-
both in PEM format. It is used to configure mutual TLS channel. It is
147+
both in PEM format. It is used to configure a mutual TLS channel. It is
148148
ignored if ``channel`` or ``ssl_channel_credentials`` is provided.
149149
quota_project_id (Optional[str]): An optional project to use for billing
150150
and quota.

0 commit comments

Comments
 (0)