@@ -302,12 +302,20 @@ def sample_list_functions():
302
302
)
303
303
304
304
# Send the request.
305
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
305
+ response = await rpc (
306
+ request ,
307
+ retry = retry ,
308
+ timeout = timeout ,
309
+ metadata = metadata ,
310
+ )
306
311
307
312
# This method is paged; wrap the response in a pager, which provides
308
313
# an `__aiter__` convenience method.
309
314
response = pagers .ListFunctionsAsyncPager (
310
- method = rpc , request = request , response = response , metadata = metadata ,
315
+ method = rpc ,
316
+ request = request ,
317
+ response = response ,
318
+ metadata = metadata ,
311
319
)
312
320
313
321
# Done; return the response.
@@ -413,7 +421,12 @@ def sample_get_function():
413
421
)
414
422
415
423
# Send the request.
416
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
424
+ response = await rpc (
425
+ request ,
426
+ retry = retry ,
427
+ timeout = timeout ,
428
+ metadata = metadata ,
429
+ )
417
430
418
431
# Done; return the response.
419
432
return response
@@ -526,7 +539,12 @@ def sample_create_function():
526
539
)
527
540
528
541
# Send the request.
529
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
542
+ response = await rpc (
543
+ request ,
544
+ retry = retry ,
545
+ timeout = timeout ,
546
+ metadata = metadata ,
547
+ )
530
548
531
549
# Wrap the response in an operation future.
532
550
response = operation_async .from_gapic (
@@ -646,7 +664,12 @@ def sample_update_function():
646
664
)
647
665
648
666
# Send the request.
649
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
667
+ response = await rpc (
668
+ request ,
669
+ retry = retry ,
670
+ timeout = timeout ,
671
+ metadata = metadata ,
672
+ )
650
673
651
674
# Wrap the response in an operation future.
652
675
response = operation_async .from_gapic (
@@ -775,7 +798,12 @@ def sample_delete_function():
775
798
)
776
799
777
800
# Send the request.
778
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
801
+ response = await rpc (
802
+ request ,
803
+ retry = retry ,
804
+ timeout = timeout ,
805
+ metadata = metadata ,
806
+ )
779
807
780
808
# Wrap the response in an operation future.
781
809
response = operation_async .from_gapic (
@@ -886,7 +914,12 @@ def sample_call_function():
886
914
)
887
915
888
916
# Send the request.
889
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
917
+ response = await rpc (
918
+ request ,
919
+ retry = retry ,
920
+ timeout = timeout ,
921
+ metadata = metadata ,
922
+ )
890
923
891
924
# Done; return the response.
892
925
return response
@@ -979,7 +1012,12 @@ def sample_generate_upload_url():
979
1012
)
980
1013
981
1014
# Send the request.
982
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1015
+ response = await rpc (
1016
+ request ,
1017
+ retry = retry ,
1018
+ timeout = timeout ,
1019
+ metadata = metadata ,
1020
+ )
983
1021
984
1022
# Done; return the response.
985
1023
return response
@@ -1050,7 +1088,12 @@ def sample_generate_download_url():
1050
1088
)
1051
1089
1052
1090
# Send the request.
1053
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1091
+ response = await rpc (
1092
+ request ,
1093
+ retry = retry ,
1094
+ timeout = timeout ,
1095
+ metadata = metadata ,
1096
+ )
1054
1097
1055
1098
# Done; return the response.
1056
1099
return response
@@ -1176,7 +1219,12 @@ def sample_set_iam_policy():
1176
1219
)
1177
1220
1178
1221
# Send the request.
1179
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1222
+ response = await rpc (
1223
+ request ,
1224
+ retry = retry ,
1225
+ timeout = timeout ,
1226
+ metadata = metadata ,
1227
+ )
1180
1228
1181
1229
# Done; return the response.
1182
1230
return response
@@ -1303,7 +1351,12 @@ def sample_get_iam_policy():
1303
1351
)
1304
1352
1305
1353
# Send the request.
1306
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1354
+ response = await rpc (
1355
+ request ,
1356
+ retry = retry ,
1357
+ timeout = timeout ,
1358
+ metadata = metadata ,
1359
+ )
1307
1360
1308
1361
# Done; return the response.
1309
1362
return response
@@ -1376,7 +1429,12 @@ def sample_test_iam_permissions():
1376
1429
)
1377
1430
1378
1431
# Send the request.
1379
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1432
+ response = await rpc (
1433
+ request ,
1434
+ retry = retry ,
1435
+ timeout = timeout ,
1436
+ metadata = metadata ,
1437
+ )
1380
1438
1381
1439
# Done; return the response.
1382
1440
return response
@@ -1390,7 +1448,9 @@ async def __aexit__(self, exc_type, exc, tb):
1390
1448
1391
1449
try :
1392
1450
DEFAULT_CLIENT_INFO = gapic_v1 .client_info .ClientInfo (
1393
- gapic_version = pkg_resources .get_distribution ("google-cloud-functions" ,).version ,
1451
+ gapic_version = pkg_resources .get_distribution (
1452
+ "google-cloud-functions" ,
1453
+ ).version ,
1394
1454
)
1395
1455
except pkg_resources .DistributionNotFound :
1396
1456
DEFAULT_CLIENT_INFO = gapic_v1 .client_info .ClientInfo ()
0 commit comments