Skip to content

Commit 5a52413

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
chore(python): use black==22.3.0 (#243)
Source-Link: googleapis/synthtool@6fab84a Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-python:latest@sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe
1 parent 9588ec0 commit 5a52413

File tree

33 files changed

+5506
-1542
lines changed

33 files changed

+5506
-1542
lines changed

‎packages/google-cloud-tasks/.github/.OwlBot.lock.yaml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# limitations under the License.
1414
docker:
1515
image: gcr.io/cloud-devrel-public-resources/owlbot-python:latest
16-
digest: sha256:2d13c2172a5d6129c861edaa48b60ead15aeaf58aa75e02d870c4cbdfa63aaba
16+
digest: sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe

‎packages/google-cloud-tasks/docs/conf.py‎

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -314,7 +314,13 @@
314314
# One entry per manual page. List of tuples
315315
# (source start file, name, description, authors, manual section).
316316
man_pages = [
317-
(root_doc, "google-cloud-tasks", "google-cloud-tasks Documentation", [author], 1,)
317+
(
318+
root_doc,
319+
"google-cloud-tasks",
320+
"google-cloud-tasks Documentation",
321+
[author],
322+
1,
323+
)
318324
]
319325

320326
# If true, show URL addresses after external links.
@@ -355,7 +361,10 @@
355361
intersphinx_mapping = {
356362
"python": ("https://python.readthedocs.org/en/latest/", None),
357363
"google-auth": ("https://googleapis.dev/python/google-auth/latest/", None),
358-
"google.api_core": ("https://googleapis.dev/python/google-api-core/latest/", None,),
364+
"google.api_core": (
365+
"https://googleapis.dev/python/google-api-core/latest/",
366+
None,
367+
),
359368
"grpc": ("https://grpc.github.io/grpc/python/", None),
360369
"proto-plus": ("https://proto-plus-python.readthedocs.io/en/latest/", None),
361370
"protobuf": ("https://googleapis.dev/python/protobuf/latest/", None),

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

Lines changed: 111 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -311,12 +311,20 @@ def sample_list_queues():
311311
)
312312

313313
# Send the request.
314-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
314+
response = await rpc(
315+
request,
316+
retry=retry,
317+
timeout=timeout,
318+
metadata=metadata,
319+
)
315320

316321
# This method is paged; wrap the response in a pager, which provides
317322
# an `__aiter__` convenience method.
318323
response = pagers.ListQueuesAsyncPager(
319-
method=rpc, request=request, response=response, metadata=metadata,
324+
method=rpc,
325+
request=request,
326+
response=response,
327+
metadata=metadata,
320328
)
321329

322330
# Done; return the response.
@@ -421,7 +429,12 @@ def sample_get_queue():
421429
)
422430

423431
# Send the request.
424-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
432+
response = await rpc(
433+
request,
434+
retry=retry,
435+
timeout=timeout,
436+
metadata=metadata,
437+
)
425438

426439
# Done; return the response.
427440
return response
@@ -543,7 +556,12 @@ def sample_create_queue():
543556
)
544557

545558
# Send the request.
546-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
559+
response = await rpc(
560+
request,
561+
retry=retry,
562+
timeout=timeout,
563+
metadata=metadata,
564+
)
547565

548566
# Done; return the response.
549567
return response
@@ -672,7 +690,12 @@ def sample_update_queue():
672690
)
673691

674692
# Send the request.
675-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
693+
response = await rpc(
694+
request,
695+
retry=retry,
696+
timeout=timeout,
697+
metadata=metadata,
698+
)
676699

677700
# Done; return the response.
678701
return response
@@ -776,7 +799,10 @@ def sample_delete_queue():
776799

777800
# Send the request.
778801
await rpc(
779-
request, retry=retry, timeout=timeout, metadata=metadata,
802+
request,
803+
retry=retry,
804+
timeout=timeout,
805+
metadata=metadata,
780806
)
781807

782808
async def purge_queue(
@@ -874,7 +900,12 @@ def sample_purge_queue():
874900
)
875901

876902
# Send the request.
877-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
903+
response = await rpc(
904+
request,
905+
retry=retry,
906+
timeout=timeout,
907+
metadata=metadata,
908+
)
878909

879910
# Done; return the response.
880911
return response
@@ -976,7 +1007,12 @@ def sample_pause_queue():
9761007
)
9771008

9781009
# Send the request.
979-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1010+
response = await rpc(
1011+
request,
1012+
retry=retry,
1013+
timeout=timeout,
1014+
metadata=metadata,
1015+
)
9801016

9811017
# Done; return the response.
9821018
return response
@@ -1085,7 +1121,12 @@ def sample_resume_queue():
10851121
)
10861122

10871123
# Send the request.
1088-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1124+
response = await rpc(
1125+
request,
1126+
retry=retry,
1127+
timeout=timeout,
1128+
metadata=metadata,
1129+
)
10891130

10901131
# Done; return the response.
10911132
return response
@@ -1222,7 +1263,9 @@ def sample_get_iam_policy():
12221263
if isinstance(request, dict):
12231264
request = iam_policy_pb2.GetIamPolicyRequest(**request)
12241265
elif not request:
1225-
request = iam_policy_pb2.GetIamPolicyRequest(resource=resource,)
1266+
request = iam_policy_pb2.GetIamPolicyRequest(
1267+
resource=resource,
1268+
)
12261269

12271270
# Wrap the RPC method; this adds retry and timeout information,
12281271
# and friendly error handling.
@@ -1249,7 +1292,12 @@ def sample_get_iam_policy():
12491292
)
12501293

12511294
# Send the request.
1252-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1295+
response = await rpc(
1296+
request,
1297+
retry=retry,
1298+
timeout=timeout,
1299+
metadata=metadata,
1300+
)
12531301

12541302
# Done; return the response.
12551303
return response
@@ -1390,7 +1438,9 @@ def sample_set_iam_policy():
13901438
if isinstance(request, dict):
13911439
request = iam_policy_pb2.SetIamPolicyRequest(**request)
13921440
elif not request:
1393-
request = iam_policy_pb2.SetIamPolicyRequest(resource=resource,)
1441+
request = iam_policy_pb2.SetIamPolicyRequest(
1442+
resource=resource,
1443+
)
13941444

13951445
# Wrap the RPC method; this adds retry and timeout information,
13961446
# and friendly error handling.
@@ -1407,7 +1457,12 @@ def sample_set_iam_policy():
14071457
)
14081458

14091459
# Send the request.
1410-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1460+
response = await rpc(
1461+
request,
1462+
retry=retry,
1463+
timeout=timeout,
1464+
metadata=metadata,
1465+
)
14111466

14121467
# Done; return the response.
14131468
return response
@@ -1501,7 +1556,8 @@ def sample_test_iam_permissions():
15011556
request = iam_policy_pb2.TestIamPermissionsRequest(**request)
15021557
elif not request:
15031558
request = iam_policy_pb2.TestIamPermissionsRequest(
1504-
resource=resource, permissions=permissions,
1559+
resource=resource,
1560+
permissions=permissions,
15051561
)
15061562

15071563
# Wrap the RPC method; this adds retry and timeout information,
@@ -1529,7 +1585,12 @@ def sample_test_iam_permissions():
15291585
)
15301586

15311587
# Send the request.
1532-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1588+
response = await rpc(
1589+
request,
1590+
retry=retry,
1591+
timeout=timeout,
1592+
metadata=metadata,
1593+
)
15331594

15341595
# Done; return the response.
15351596
return response
@@ -1644,12 +1705,20 @@ def sample_list_tasks():
16441705
)
16451706

16461707
# Send the request.
1647-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1708+
response = await rpc(
1709+
request,
1710+
retry=retry,
1711+
timeout=timeout,
1712+
metadata=metadata,
1713+
)
16481714

16491715
# This method is paged; wrap the response in a pager, which provides
16501716
# an `__aiter__` convenience method.
16511717
response = pagers.ListTasksAsyncPager(
1652-
method=rpc, request=request, response=response, metadata=metadata,
1718+
method=rpc,
1719+
request=request,
1720+
response=response,
1721+
metadata=metadata,
16531722
)
16541723

16551724
# Done; return the response.
@@ -1749,7 +1818,12 @@ def sample_get_task():
17491818
)
17501819

17511820
# Send the request.
1752-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1821+
response = await rpc(
1822+
request,
1823+
retry=retry,
1824+
timeout=timeout,
1825+
metadata=metadata,
1826+
)
17531827

17541828
# Done; return the response.
17551829
return response
@@ -1894,7 +1968,12 @@ def sample_create_task():
18941968
)
18951969

18961970
# Send the request.
1897-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1971+
response = await rpc(
1972+
request,
1973+
retry=retry,
1974+
timeout=timeout,
1975+
metadata=metadata,
1976+
)
18981977

18991978
# Done; return the response.
19001979
return response
@@ -1991,7 +2070,10 @@ def sample_delete_task():
19912070

19922071
# Send the request.
19932072
await rpc(
1994-
request, retry=retry, timeout=timeout, metadata=metadata,
2073+
request,
2074+
retry=retry,
2075+
timeout=timeout,
2076+
metadata=metadata,
19952077
)
19962078

19972079
async def run_task(
@@ -2105,7 +2187,12 @@ def sample_run_task():
21052187
)
21062188

21072189
# Send the request.
2108-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2190+
response = await rpc(
2191+
request,
2192+
retry=retry,
2193+
timeout=timeout,
2194+
metadata=metadata,
2195+
)
21092196

21102197
# Done; return the response.
21112198
return response
@@ -2119,7 +2206,9 @@ async def __aexit__(self, exc_type, exc, tb):
21192206

21202207
try:
21212208
DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo(
2122-
gapic_version=pkg_resources.get_distribution("google-cloud-tasks",).version,
2209+
gapic_version=pkg_resources.get_distribution(
2210+
"google-cloud-tasks",
2211+
).version,
21232212
)
21242213
except pkg_resources.DistributionNotFound:
21252214
DEFAULT_CLIENT_INFO = gapic_v1.client_info.ClientInfo()

0 commit comments

Comments
 (0)