Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit fa56113

Browse filesBrowse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
chore: use gapic-generator-python 0.53.4 (#187)
- [ ] 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: googleapis/googleapis-gen@2ff001f Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMmZmMDAxZmJhY2I5ZTc3ZTcxZDczNGRlNWY5NTVjMDVmZGFlODUyNiJ9
1 parent 38caaf4 commit fa56113
Copy full SHA for fa56113

File tree

Expand file treeCollapse file tree

24 files changed

+323
-558
lines changed
Filter options
Expand file treeCollapse file tree

24 files changed

+323
-558
lines changed

‎packages/google-cloud-tasks/google/cloud/tasks_v2/services/cloud_tasks/async_client.py

Copy file name to clipboardExpand all lines: packages/google-cloud-tasks/google/cloud/tasks_v2/services/cloud_tasks/async_client.py
+51-49Lines changed: 51 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,15 @@
1919
from typing import Dict, Sequence, Tuple, Type, Union
2020
import pkg_resources
2121

22-
import google.api_core.client_options as ClientOptions # type: ignore
22+
from google.api_core.client_options import ClientOptions # type: ignore
2323
from google.api_core import exceptions as core_exceptions # type: ignore
2424
from google.api_core import gapic_v1 # type: ignore
2525
from google.api_core import retry as retries # type: ignore
2626
from google.auth import credentials as ga_credentials # type: ignore
2727
from google.oauth2 import service_account # type: ignore
2828

29+
OptionalRetry = Union[retries.Retry, object]
30+
2931
from google.cloud.tasks_v2.services.cloud_tasks import pagers
3032
from google.cloud.tasks_v2.types import cloudtasks
3133
from google.cloud.tasks_v2.types import queue
@@ -171,18 +173,18 @@ def __init__(
171173

172174
async def list_queues(
173175
self,
174-
request: cloudtasks.ListQueuesRequest = None,
176+
request: Union[cloudtasks.ListQueuesRequest, dict] = None,
175177
*,
176178
parent: str = None,
177-
retry: retries.Retry = gapic_v1.method.DEFAULT,
179+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
178180
timeout: float = None,
179181
metadata: Sequence[Tuple[str, str]] = (),
180182
) -> pagers.ListQueuesAsyncPager:
181183
r"""Lists queues.
182184
Queues are returned in lexicographical order.
183185
184186
Args:
185-
request (:class:`google.cloud.tasks_v2.types.ListQueuesRequest`):
187+
request (Union[google.cloud.tasks_v2.types.ListQueuesRequest, dict]):
186188
The request object. Request message for
187189
[ListQueues][google.cloud.tasks.v2.CloudTasks.ListQueues].
188190
parent (:class:`str`):
@@ -262,17 +264,17 @@ async def list_queues(
262264

263265
async def get_queue(
264266
self,
265-
request: cloudtasks.GetQueueRequest = None,
267+
request: Union[cloudtasks.GetQueueRequest, dict] = None,
266268
*,
267269
name: str = None,
268-
retry: retries.Retry = gapic_v1.method.DEFAULT,
270+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
269271
timeout: float = None,
270272
metadata: Sequence[Tuple[str, str]] = (),
271273
) -> queue.Queue:
272274
r"""Gets a queue.
273275
274276
Args:
275-
request (:class:`google.cloud.tasks_v2.types.GetQueueRequest`):
277+
request (Union[google.cloud.tasks_v2.types.GetQueueRequest, dict]):
276278
The request object. Request message for
277279
[GetQueue][google.cloud.tasks.v2.CloudTasks.GetQueue].
278280
name (:class:`str`):
@@ -347,11 +349,11 @@ async def get_queue(
347349

348350
async def create_queue(
349351
self,
350-
request: cloudtasks.CreateQueueRequest = None,
352+
request: Union[cloudtasks.CreateQueueRequest, dict] = None,
351353
*,
352354
parent: str = None,
353355
queue: gct_queue.Queue = None,
354-
retry: retries.Retry = gapic_v1.method.DEFAULT,
356+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
355357
timeout: float = None,
356358
metadata: Sequence[Tuple[str, str]] = (),
357359
) -> gct_queue.Queue:
@@ -368,7 +370,7 @@ async def create_queue(
368370
before using this method.
369371
370372
Args:
371-
request (:class:`google.cloud.tasks_v2.types.CreateQueueRequest`):
373+
request (Union[google.cloud.tasks_v2.types.CreateQueueRequest, dict]):
372374
The request object. Request message for
373375
[CreateQueue][google.cloud.tasks.v2.CloudTasks.CreateQueue].
374376
parent (:class:`str`):
@@ -449,11 +451,11 @@ async def create_queue(
449451

450452
async def update_queue(
451453
self,
452-
request: cloudtasks.UpdateQueueRequest = None,
454+
request: Union[cloudtasks.UpdateQueueRequest, dict] = None,
453455
*,
454456
queue: gct_queue.Queue = None,
455457
update_mask: field_mask_pb2.FieldMask = None,
456-
retry: retries.Retry = gapic_v1.method.DEFAULT,
458+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
457459
timeout: float = None,
458460
metadata: Sequence[Tuple[str, str]] = (),
459461
) -> gct_queue.Queue:
@@ -473,7 +475,7 @@ async def update_queue(
473475
before using this method.
474476
475477
Args:
476-
request (:class:`google.cloud.tasks_v2.types.UpdateQueueRequest`):
478+
request (Union[google.cloud.tasks_v2.types.UpdateQueueRequest, dict]):
477479
The request object. Request message for
478480
[UpdateQueue][google.cloud.tasks.v2.CloudTasks.UpdateQueue].
479481
queue (:class:`google.cloud.tasks_v2.types.Queue`):
@@ -559,10 +561,10 @@ async def update_queue(
559561

560562
async def delete_queue(
561563
self,
562-
request: cloudtasks.DeleteQueueRequest = None,
564+
request: Union[cloudtasks.DeleteQueueRequest, dict] = None,
563565
*,
564566
name: str = None,
565-
retry: retries.Retry = gapic_v1.method.DEFAULT,
567+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
566568
timeout: float = None,
567569
metadata: Sequence[Tuple[str, str]] = (),
568570
) -> None:
@@ -580,7 +582,7 @@ async def delete_queue(
580582
before using this method.
581583
582584
Args:
583-
request (:class:`google.cloud.tasks_v2.types.DeleteQueueRequest`):
585+
request (Union[google.cloud.tasks_v2.types.DeleteQueueRequest, dict]):
584586
The request object. Request message for
585587
[DeleteQueue][google.cloud.tasks.v2.CloudTasks.DeleteQueue].
586588
name (:class:`str`):
@@ -644,10 +646,10 @@ async def delete_queue(
644646

645647
async def purge_queue(
646648
self,
647-
request: cloudtasks.PurgeQueueRequest = None,
649+
request: Union[cloudtasks.PurgeQueueRequest, dict] = None,
648650
*,
649651
name: str = None,
650-
retry: retries.Retry = gapic_v1.method.DEFAULT,
652+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
651653
timeout: float = None,
652654
metadata: Sequence[Tuple[str, str]] = (),
653655
) -> queue.Queue:
@@ -659,7 +661,7 @@ async def purge_queue(
659661
effect. A purge is irreversible.
660662
661663
Args:
662-
request (:class:`google.cloud.tasks_v2.types.PurgeQueueRequest`):
664+
request (Union[google.cloud.tasks_v2.types.PurgeQueueRequest, dict]):
663665
The request object. Request message for
664666
[PurgeQueue][google.cloud.tasks.v2.CloudTasks.PurgeQueue].
665667
name (:class:`str`):
@@ -724,10 +726,10 @@ async def purge_queue(
724726

725727
async def pause_queue(
726728
self,
727-
request: cloudtasks.PauseQueueRequest = None,
729+
request: Union[cloudtasks.PauseQueueRequest, dict] = None,
728730
*,
729731
name: str = None,
730-
retry: retries.Retry = gapic_v1.method.DEFAULT,
732+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
731733
timeout: float = None,
732734
metadata: Sequence[Tuple[str, str]] = (),
733735
) -> queue.Queue:
@@ -741,7 +743,7 @@ async def pause_queue(
741743
[PAUSED][google.cloud.tasks.v2.Queue.State.PAUSED].
742744
743745
Args:
744-
request (:class:`google.cloud.tasks_v2.types.PauseQueueRequest`):
746+
request (Union[google.cloud.tasks_v2.types.PauseQueueRequest, dict]):
745747
The request object. Request message for
746748
[PauseQueue][google.cloud.tasks.v2.CloudTasks.PauseQueue].
747749
name (:class:`str`):
@@ -806,10 +808,10 @@ async def pause_queue(
806808

807809
async def resume_queue(
808810
self,
809-
request: cloudtasks.ResumeQueueRequest = None,
811+
request: Union[cloudtasks.ResumeQueueRequest, dict] = None,
810812
*,
811813
name: str = None,
812-
retry: retries.Retry = gapic_v1.method.DEFAULT,
814+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
813815
timeout: float = None,
814816
metadata: Sequence[Tuple[str, str]] = (),
815817
) -> queue.Queue:
@@ -830,7 +832,7 @@ async def resume_queue(
830832
Risks <https://cloud.google.com/tasks/docs/manage-cloud-task-scaling>`__.
831833
832834
Args:
833-
request (:class:`google.cloud.tasks_v2.types.ResumeQueueRequest`):
835+
request (Union[google.cloud.tasks_v2.types.ResumeQueueRequest, dict]):
834836
The request object. Request message for
835837
[ResumeQueue][google.cloud.tasks.v2.CloudTasks.ResumeQueue].
836838
name (:class:`str`):
@@ -895,10 +897,10 @@ async def resume_queue(
895897

896898
async def get_iam_policy(
897899
self,
898-
request: iam_policy_pb2.GetIamPolicyRequest = None,
900+
request: Union[iam_policy_pb2.GetIamPolicyRequest, dict] = None,
899901
*,
900902
resource: str = None,
901-
retry: retries.Retry = gapic_v1.method.DEFAULT,
903+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
902904
timeout: float = None,
903905
metadata: Sequence[Tuple[str, str]] = (),
904906
) -> policy_pb2.Policy:
@@ -913,7 +915,7 @@ async def get_iam_policy(
913915
- ``cloudtasks.queues.getIamPolicy``
914916
915917
Args:
916-
request (:class:`google.iam.v1.iam_policy_pb2.GetIamPolicyRequest`):
918+
request (Union[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest, dict]):
917919
The request object. Request message for `GetIamPolicy`
918920
method.
919921
resource (:class:`str`):
@@ -1039,10 +1041,10 @@ async def get_iam_policy(
10391041

10401042
async def set_iam_policy(
10411043
self,
1042-
request: iam_policy_pb2.SetIamPolicyRequest = None,
1044+
request: Union[iam_policy_pb2.SetIamPolicyRequest, dict] = None,
10431045
*,
10441046
resource: str = None,
1045-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1047+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
10461048
timeout: float = None,
10471049
metadata: Sequence[Tuple[str, str]] = (),
10481050
) -> policy_pb2.Policy:
@@ -1061,7 +1063,7 @@ async def set_iam_policy(
10611063
- ``cloudtasks.queues.setIamPolicy``
10621064
10631065
Args:
1064-
request (:class:`google.iam.v1.iam_policy_pb2.SetIamPolicyRequest`):
1066+
request (Union[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest, dict]):
10651067
The request object. Request message for `SetIamPolicy`
10661068
method.
10671069
resource (:class:`str`):
@@ -1177,11 +1179,11 @@ async def set_iam_policy(
11771179

11781180
async def test_iam_permissions(
11791181
self,
1180-
request: iam_policy_pb2.TestIamPermissionsRequest = None,
1182+
request: Union[iam_policy_pb2.TestIamPermissionsRequest, dict] = None,
11811183
*,
11821184
resource: str = None,
11831185
permissions: Sequence[str] = None,
1184-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1186+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
11851187
timeout: float = None,
11861188
metadata: Sequence[Tuple[str, str]] = (),
11871189
) -> iam_policy_pb2.TestIamPermissionsResponse:
@@ -1196,7 +1198,7 @@ async def test_iam_permissions(
11961198
warning.
11971199
11981200
Args:
1199-
request (:class:`google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest`):
1201+
request (Union[google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest, dict]):
12001202
The request object. Request message for
12011203
`TestIamPermissions` method.
12021204
resource (:class:`str`):
@@ -1278,10 +1280,10 @@ async def test_iam_permissions(
12781280

12791281
async def list_tasks(
12801282
self,
1281-
request: cloudtasks.ListTasksRequest = None,
1283+
request: Union[cloudtasks.ListTasksRequest, dict] = None,
12821284
*,
12831285
parent: str = None,
1284-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1286+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
12851287
timeout: float = None,
12861288
metadata: Sequence[Tuple[str, str]] = (),
12871289
) -> pagers.ListTasksAsyncPager:
@@ -1297,7 +1299,7 @@ async def list_tasks(
12971299
at any time.
12981300
12991301
Args:
1300-
request (:class:`google.cloud.tasks_v2.types.ListTasksRequest`):
1302+
request (Union[google.cloud.tasks_v2.types.ListTasksRequest, dict]):
13011303
The request object. Request message for listing tasks
13021304
using
13031305
[ListTasks][google.cloud.tasks.v2.CloudTasks.ListTasks].
@@ -1378,17 +1380,17 @@ async def list_tasks(
13781380

13791381
async def get_task(
13801382
self,
1381-
request: cloudtasks.GetTaskRequest = None,
1383+
request: Union[cloudtasks.GetTaskRequest, dict] = None,
13821384
*,
13831385
name: str = None,
1384-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1386+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
13851387
timeout: float = None,
13861388
metadata: Sequence[Tuple[str, str]] = (),
13871389
) -> task.Task:
13881390
r"""Gets a task.
13891391
13901392
Args:
1391-
request (:class:`google.cloud.tasks_v2.types.GetTaskRequest`):
1393+
request (Union[google.cloud.tasks_v2.types.GetTaskRequest, dict]):
13921394
The request object. Request message for getting a task
13931395
using
13941396
[GetTask][google.cloud.tasks.v2.CloudTasks.GetTask].
@@ -1458,11 +1460,11 @@ async def get_task(
14581460

14591461
async def create_task(
14601462
self,
1461-
request: cloudtasks.CreateTaskRequest = None,
1463+
request: Union[cloudtasks.CreateTaskRequest, dict] = None,
14621464
*,
14631465
parent: str = None,
14641466
task: gct_task.Task = None,
1465-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1467+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
14661468
timeout: float = None,
14671469
metadata: Sequence[Tuple[str, str]] = (),
14681470
) -> gct_task.Task:
@@ -1474,7 +1476,7 @@ async def create_task(
14741476
- The maximum task size is 100KB.
14751477
14761478
Args:
1477-
request (:class:`google.cloud.tasks_v2.types.CreateTaskRequest`):
1479+
request (Union[google.cloud.tasks_v2.types.CreateTaskRequest, dict]):
14781480
The request object. Request message for
14791481
[CreateTask][google.cloud.tasks.v2.CloudTasks.CreateTask].
14801482
parent (:class:`str`):
@@ -1583,10 +1585,10 @@ async def create_task(
15831585

15841586
async def delete_task(
15851587
self,
1586-
request: cloudtasks.DeleteTaskRequest = None,
1588+
request: Union[cloudtasks.DeleteTaskRequest, dict] = None,
15871589
*,
15881590
name: str = None,
1589-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1591+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
15901592
timeout: float = None,
15911593
metadata: Sequence[Tuple[str, str]] = (),
15921594
) -> None:
@@ -1596,7 +1598,7 @@ async def delete_task(
15961598
or permanently failed.
15971599
15981600
Args:
1599-
request (:class:`google.cloud.tasks_v2.types.DeleteTaskRequest`):
1601+
request (Union[google.cloud.tasks_v2.types.DeleteTaskRequest, dict]):
16001602
The request object. Request message for deleting a task
16011603
using
16021604
[DeleteTask][google.cloud.tasks.v2.CloudTasks.DeleteTask].
@@ -1661,10 +1663,10 @@ async def delete_task(
16611663

16621664
async def run_task(
16631665
self,
1664-
request: cloudtasks.RunTaskRequest = None,
1666+
request: Union[cloudtasks.RunTaskRequest, dict] = None,
16651667
*,
16661668
name: str = None,
1667-
retry: retries.Retry = gapic_v1.method.DEFAULT,
1669+
retry: OptionalRetry = gapic_v1.method.DEFAULT,
16681670
timeout: float = None,
16691671
metadata: Sequence[Tuple[str, str]] = (),
16701672
) -> task.Task:
@@ -1697,7 +1699,7 @@ async def run_task(
16971699
task that has already succeeded or permanently failed.
16981700
16991701
Args:
1700-
request (:class:`google.cloud.tasks_v2.types.RunTaskRequest`):
1702+
request (Union[google.cloud.tasks_v2.types.RunTaskRequest, dict]):
17011703
The request object. Request message for forcing a task
17021704
to run now using
17031705
[RunTask][google.cloud.tasks.v2.CloudTasks.RunTask].

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.