Skip to content

Commit 474b1b5

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

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

63 files changed

+4861
-1490
lines changed

‎.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:5d8da01438ece4021d135433f2cf3227aa39ef0eaccc941d62aa35e6902832ae
16+
digest: sha256:7cffbc10910c3ab1b852c05114a08d374c195a81cdec1d4a67a1d129331d0bfe

‎docs/conf.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,7 +361,10 @@
361361
intersphinx_mapping = {
362362
"python": ("https://python.readthedocs.org/en/latest/", None),
363363
"google-auth": ("https://googleapis.dev/python/google-auth/latest/", None),
364-
"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+
),
365368
"grpc": ("https://grpc.github.io/grpc/python/", None),
366369
"proto-plus": ("https://proto-plus-python.readthedocs.io/en/latest/", None),
367370
"protobuf": ("https://googleapis.dev/python/protobuf/latest/", None),

‎google/cloud/spanner_admin_database_v1/services/database_admin/async_client.py

Lines changed: 128 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -331,12 +331,20 @@ def sample_list_databases():
331331
)
332332

333333
# Send the request.
334-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
334+
response = await rpc(
335+
request,
336+
retry=retry,
337+
timeout=timeout,
338+
metadata=metadata,
339+
)
335340

336341
# This method is paged; wrap the response in a pager, which provides
337342
# an `__aiter__` convenience method.
338343
response = pagers.ListDatabasesAsyncPager(
339-
method=rpc, request=request, response=response, metadata=metadata,
344+
method=rpc,
345+
request=request,
346+
response=response,
347+
metadata=metadata,
340348
)
341349

342350
# Done; return the response.
@@ -461,7 +469,12 @@ def sample_create_database():
461469
)
462470

463471
# Send the request.
464-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
472+
response = await rpc(
473+
request,
474+
retry=retry,
475+
timeout=timeout,
476+
metadata=metadata,
477+
)
465478

466479
# Wrap the response in an operation future.
467480
response = operation_async.from_gapic(
@@ -568,7 +581,12 @@ def sample_get_database():
568581
)
569582

570583
# Send the request.
571-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
584+
response = await rpc(
585+
request,
586+
retry=retry,
587+
timeout=timeout,
588+
metadata=metadata,
589+
)
572590

573591
# Done; return the response.
574592
return response
@@ -720,7 +738,12 @@ def sample_update_database_ddl():
720738
)
721739

722740
# Send the request.
723-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
741+
response = await rpc(
742+
request,
743+
retry=retry,
744+
timeout=timeout,
745+
metadata=metadata,
746+
)
724747

725748
# Wrap the response in an operation future.
726749
response = operation_async.from_gapic(
@@ -822,7 +845,10 @@ def sample_drop_database():
822845

823846
# Send the request.
824847
await rpc(
825-
request, retry=retry, timeout=timeout, metadata=metadata,
848+
request,
849+
retry=retry,
850+
timeout=timeout,
851+
metadata=metadata,
826852
)
827853

828854
async def get_database_ddl(
@@ -925,7 +951,12 @@ def sample_get_database_ddl():
925951
)
926952

927953
# Send the request.
928-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
954+
response = await rpc(
955+
request,
956+
retry=retry,
957+
timeout=timeout,
958+
metadata=metadata,
959+
)
929960

930961
# Done; return the response.
931962
return response
@@ -1062,7 +1093,9 @@ def sample_set_iam_policy():
10621093
if isinstance(request, dict):
10631094
request = iam_policy_pb2.SetIamPolicyRequest(**request)
10641095
elif not request:
1065-
request = iam_policy_pb2.SetIamPolicyRequest(resource=resource,)
1096+
request = iam_policy_pb2.SetIamPolicyRequest(
1097+
resource=resource,
1098+
)
10661099

10671100
# Wrap the RPC method; this adds retry and timeout information,
10681101
# and friendly error handling.
@@ -1079,7 +1112,12 @@ def sample_set_iam_policy():
10791112
)
10801113

10811114
# Send the request.
1082-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1115+
response = await rpc(
1116+
request,
1117+
retry=retry,
1118+
timeout=timeout,
1119+
metadata=metadata,
1120+
)
10831121

10841122
# Done; return the response.
10851123
return response
@@ -1217,7 +1255,9 @@ def sample_get_iam_policy():
12171255
if isinstance(request, dict):
12181256
request = iam_policy_pb2.GetIamPolicyRequest(**request)
12191257
elif not request:
1220-
request = iam_policy_pb2.GetIamPolicyRequest(resource=resource,)
1258+
request = iam_policy_pb2.GetIamPolicyRequest(
1259+
resource=resource,
1260+
)
12211261

12221262
# Wrap the RPC method; this adds retry and timeout information,
12231263
# and friendly error handling.
@@ -1244,7 +1284,12 @@ def sample_get_iam_policy():
12441284
)
12451285

12461286
# Send the request.
1247-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1287+
response = await rpc(
1288+
request,
1289+
retry=retry,
1290+
timeout=timeout,
1291+
metadata=metadata,
1292+
)
12481293

12491294
# Done; return the response.
12501295
return response
@@ -1339,7 +1384,8 @@ def sample_test_iam_permissions():
13391384
request = iam_policy_pb2.TestIamPermissionsRequest(**request)
13401385
elif not request:
13411386
request = iam_policy_pb2.TestIamPermissionsRequest(
1342-
resource=resource, permissions=permissions,
1387+
resource=resource,
1388+
permissions=permissions,
13431389
)
13441390

13451391
# Wrap the RPC method; this adds retry and timeout information,
@@ -1357,7 +1403,12 @@ def sample_test_iam_permissions():
13571403
)
13581404

13591405
# Send the request.
1360-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1406+
response = await rpc(
1407+
request,
1408+
retry=retry,
1409+
timeout=timeout,
1410+
metadata=metadata,
1411+
)
13611412

13621413
# Done; return the response.
13631414
return response
@@ -1493,7 +1544,12 @@ def sample_create_backup():
14931544
)
14941545

14951546
# Send the request.
1496-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1547+
response = await rpc(
1548+
request,
1549+
retry=retry,
1550+
timeout=timeout,
1551+
metadata=metadata,
1552+
)
14971553

14981554
# Wrap the response in an operation future.
14991555
response = operation_async.from_gapic(
@@ -1655,7 +1711,12 @@ def sample_copy_backup():
16551711
)
16561712

16571713
# Send the request.
1658-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1714+
response = await rpc(
1715+
request,
1716+
retry=retry,
1717+
timeout=timeout,
1718+
metadata=metadata,
1719+
)
16591720

16601721
# Wrap the response in an operation future.
16611722
response = operation_async.from_gapic(
@@ -1763,7 +1824,12 @@ def sample_get_backup():
17631824
)
17641825

17651826
# Send the request.
1766-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1827+
response = await rpc(
1828+
request,
1829+
retry=retry,
1830+
timeout=timeout,
1831+
metadata=metadata,
1832+
)
17671833

17681834
# Done; return the response.
17691835
return response
@@ -1883,7 +1949,12 @@ def sample_update_backup():
18831949
)
18841950

18851951
# Send the request.
1886-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
1952+
response = await rpc(
1953+
request,
1954+
retry=retry,
1955+
timeout=timeout,
1956+
metadata=metadata,
1957+
)
18871958

18881959
# Done; return the response.
18891960
return response
@@ -1978,7 +2049,10 @@ def sample_delete_backup():
19782049

19792050
# Send the request.
19802051
await rpc(
1981-
request, retry=retry, timeout=timeout, metadata=metadata,
2052+
request,
2053+
retry=retry,
2054+
timeout=timeout,
2055+
metadata=metadata,
19822056
)
19832057

19842058
async def list_backups(
@@ -2083,12 +2157,20 @@ def sample_list_backups():
20832157
)
20842158

20852159
# Send the request.
2086-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2160+
response = await rpc(
2161+
request,
2162+
retry=retry,
2163+
timeout=timeout,
2164+
metadata=metadata,
2165+
)
20872166

20882167
# This method is paged; wrap the response in a pager, which provides
20892168
# an `__aiter__` convenience method.
20902169
response = pagers.ListBackupsAsyncPager(
2091-
method=rpc, request=request, response=response, metadata=metadata,
2170+
method=rpc,
2171+
request=request,
2172+
response=response,
2173+
metadata=metadata,
20922174
)
20932175

20942176
# Done; return the response.
@@ -2234,7 +2316,12 @@ def sample_restore_database():
22342316
)
22352317

22362318
# Send the request.
2237-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2319+
response = await rpc(
2320+
request,
2321+
retry=retry,
2322+
timeout=timeout,
2323+
metadata=metadata,
2324+
)
22382325

22392326
# Wrap the response in an operation future.
22402327
response = operation_async.from_gapic(
@@ -2359,12 +2446,20 @@ def sample_list_database_operations():
23592446
)
23602447

23612448
# Send the request.
2362-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2449+
response = await rpc(
2450+
request,
2451+
retry=retry,
2452+
timeout=timeout,
2453+
metadata=metadata,
2454+
)
23632455

23642456
# This method is paged; wrap the response in a pager, which provides
23652457
# an `__aiter__` convenience method.
23662458
response = pagers.ListDatabaseOperationsAsyncPager(
2367-
method=rpc, request=request, response=response, metadata=metadata,
2459+
method=rpc,
2460+
request=request,
2461+
response=response,
2462+
metadata=metadata,
23682463
)
23692464

23702465
# Done; return the response.
@@ -2482,12 +2577,20 @@ def sample_list_backup_operations():
24822577
)
24832578

24842579
# Send the request.
2485-
response = await rpc(request, retry=retry, timeout=timeout, metadata=metadata,)
2580+
response = await rpc(
2581+
request,
2582+
retry=retry,
2583+
timeout=timeout,
2584+
metadata=metadata,
2585+
)
24862586

24872587
# This method is paged; wrap the response in a pager, which provides
24882588
# an `__aiter__` convenience method.
24892589
response = pagers.ListBackupOperationsAsyncPager(
2490-
method=rpc, request=request, response=response, metadata=metadata,
2590+
method=rpc,
2591+
request=request,
2592+
response=response,
2593+
metadata=metadata,
24912594
)
24922595

24932596
# Done; return the response.

0 commit comments

Comments
 (0)