@@ -339,7 +339,12 @@ def sample_create_channel():
339
339
)
340
340
341
341
# Send the request.
342
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
342
+ response = await rpc (
343
+ request ,
344
+ retry = retry ,
345
+ timeout = timeout ,
346
+ metadata = metadata ,
347
+ )
343
348
344
349
# Wrap the response in an operation future.
345
350
response = operation_async .from_gapic (
@@ -452,12 +457,20 @@ def sample_list_channels():
452
457
)
453
458
454
459
# Send the request.
455
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
460
+ response = await rpc (
461
+ request ,
462
+ retry = retry ,
463
+ timeout = timeout ,
464
+ metadata = metadata ,
465
+ )
456
466
457
467
# This method is paged; wrap the response in a pager, which provides
458
468
# an `__aiter__` convenience method.
459
469
response = pagers .ListChannelsAsyncPager (
460
- method = rpc , request = request , response = response , metadata = metadata ,
470
+ method = rpc ,
471
+ request = request ,
472
+ response = response ,
473
+ metadata = metadata ,
461
474
)
462
475
463
476
# Done; return the response.
@@ -564,7 +577,12 @@ def sample_get_channel():
564
577
)
565
578
566
579
# Send the request.
567
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
580
+ response = await rpc (
581
+ request ,
582
+ retry = retry ,
583
+ timeout = timeout ,
584
+ metadata = metadata ,
585
+ )
568
586
569
587
# Done; return the response.
570
588
return response
@@ -672,7 +690,12 @@ def sample_delete_channel():
672
690
)
673
691
674
692
# 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
+ )
676
699
677
700
# Wrap the response in an operation future.
678
701
response = operation_async .from_gapic (
@@ -803,7 +826,12 @@ def sample_update_channel():
803
826
)
804
827
805
828
# Send the request.
806
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
829
+ response = await rpc (
830
+ request ,
831
+ retry = retry ,
832
+ timeout = timeout ,
833
+ metadata = metadata ,
834
+ )
807
835
808
836
# Wrap the response in an operation future.
809
837
response = operation_async .from_gapic (
@@ -913,7 +941,12 @@ def sample_start_channel():
913
941
)
914
942
915
943
# Send the request.
916
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
944
+ response = await rpc (
945
+ request ,
946
+ retry = retry ,
947
+ timeout = timeout ,
948
+ metadata = metadata ,
949
+ )
917
950
918
951
# Wrap the response in an operation future.
919
952
response = operation_async .from_gapic (
@@ -1023,7 +1056,12 @@ def sample_stop_channel():
1023
1056
)
1024
1057
1025
1058
# Send the request.
1026
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1059
+ response = await rpc (
1060
+ request ,
1061
+ retry = retry ,
1062
+ timeout = timeout ,
1063
+ metadata = metadata ,
1064
+ )
1027
1065
1028
1066
# Wrap the response in an operation future.
1029
1067
response = operation_async .from_gapic (
@@ -1151,7 +1189,12 @@ def sample_create_input():
1151
1189
)
1152
1190
1153
1191
# Send the request.
1154
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1192
+ response = await rpc (
1193
+ request ,
1194
+ retry = retry ,
1195
+ timeout = timeout ,
1196
+ metadata = metadata ,
1197
+ )
1155
1198
1156
1199
# Wrap the response in an operation future.
1157
1200
response = operation_async .from_gapic (
@@ -1262,12 +1305,20 @@ def sample_list_inputs():
1262
1305
)
1263
1306
1264
1307
# Send the request.
1265
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1308
+ response = await rpc (
1309
+ request ,
1310
+ retry = retry ,
1311
+ timeout = timeout ,
1312
+ metadata = metadata ,
1313
+ )
1266
1314
1267
1315
# This method is paged; wrap the response in a pager, which provides
1268
1316
# an `__aiter__` convenience method.
1269
1317
response = pagers .ListInputsAsyncPager (
1270
- method = rpc , request = request , response = response , metadata = metadata ,
1318
+ method = rpc ,
1319
+ request = request ,
1320
+ response = response ,
1321
+ metadata = metadata ,
1271
1322
)
1272
1323
1273
1324
# Done; return the response.
@@ -1369,7 +1420,12 @@ def sample_get_input():
1369
1420
)
1370
1421
1371
1422
# Send the request.
1372
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1423
+ response = await rpc (
1424
+ request ,
1425
+ retry = retry ,
1426
+ timeout = timeout ,
1427
+ metadata = metadata ,
1428
+ )
1373
1429
1374
1430
# Done; return the response.
1375
1431
return response
@@ -1477,7 +1533,12 @@ def sample_delete_input():
1477
1533
)
1478
1534
1479
1535
# Send the request.
1480
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1536
+ response = await rpc (
1537
+ request ,
1538
+ retry = retry ,
1539
+ timeout = timeout ,
1540
+ metadata = metadata ,
1541
+ )
1481
1542
1482
1543
# Wrap the response in an operation future.
1483
1544
response = operation_async .from_gapic (
@@ -1600,7 +1661,12 @@ def sample_update_input():
1600
1661
)
1601
1662
1602
1663
# Send the request.
1603
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1664
+ response = await rpc (
1665
+ request ,
1666
+ retry = retry ,
1667
+ timeout = timeout ,
1668
+ metadata = metadata ,
1669
+ )
1604
1670
1605
1671
# Wrap the response in an operation future.
1606
1672
response = operation_async .from_gapic (
@@ -1725,7 +1791,12 @@ def sample_create_event():
1725
1791
)
1726
1792
1727
1793
# Send the request.
1728
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1794
+ response = await rpc (
1795
+ request ,
1796
+ retry = retry ,
1797
+ timeout = timeout ,
1798
+ metadata = metadata ,
1799
+ )
1729
1800
1730
1801
# Done; return the response.
1731
1802
return response
@@ -1831,12 +1902,20 @@ def sample_list_events():
1831
1902
)
1832
1903
1833
1904
# Send the request.
1834
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1905
+ response = await rpc (
1906
+ request ,
1907
+ retry = retry ,
1908
+ timeout = timeout ,
1909
+ metadata = metadata ,
1910
+ )
1835
1911
1836
1912
# This method is paged; wrap the response in a pager, which provides
1837
1913
# an `__aiter__` convenience method.
1838
1914
response = pagers .ListEventsAsyncPager (
1839
- method = rpc , request = request , response = response , metadata = metadata ,
1915
+ method = rpc ,
1916
+ request = request ,
1917
+ response = response ,
1918
+ metadata = metadata ,
1840
1919
)
1841
1920
1842
1921
# Done; return the response.
@@ -1939,7 +2018,12 @@ def sample_get_event():
1939
2018
)
1940
2019
1941
2020
# Send the request.
1942
- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
2021
+ response = await rpc (
2022
+ request ,
2023
+ retry = retry ,
2024
+ timeout = timeout ,
2025
+ metadata = metadata ,
2026
+ )
1943
2027
1944
2028
# Done; return the response.
1945
2029
return response
@@ -2022,7 +2106,10 @@ def sample_delete_event():
2022
2106
2023
2107
# Send the request.
2024
2108
await rpc (
2025
- request , retry = retry , timeout = timeout , metadata = metadata ,
2109
+ request ,
2110
+ retry = retry ,
2111
+ timeout = timeout ,
2112
+ metadata = metadata ,
2026
2113
)
2027
2114
2028
2115
async def __aenter__ (self ):
0 commit comments