@@ -337,7 +337,12 @@ def sample_create_dataset():
337337 )
338338
339339 # Send the request.
340- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
340+ response = await rpc (
341+ request ,
342+ retry = retry ,
343+ timeout = timeout ,
344+ metadata = metadata ,
345+ )
341346
342347 # Wrap the response in an operation future.
343348 response = operation_async .from_gapic (
@@ -447,7 +452,12 @@ def sample_get_dataset():
447452 )
448453
449454 # Send the request.
450- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
455+ response = await rpc (
456+ request ,
457+ retry = retry ,
458+ timeout = timeout ,
459+ metadata = metadata ,
460+ )
451461
452462 # Done; return the response.
453463 return response
@@ -551,12 +561,20 @@ def sample_list_datasets():
551561 )
552562
553563 # Send the request.
554- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
564+ response = await rpc (
565+ request ,
566+ retry = retry ,
567+ timeout = timeout ,
568+ metadata = metadata ,
569+ )
555570
556571 # This method is paged; wrap the response in a pager, which provides
557572 # an `__aiter__` convenience method.
558573 response = pagers .ListDatasetsAsyncPager (
559- method = rpc , request = request , response = response , metadata = metadata ,
574+ method = rpc ,
575+ request = request ,
576+ response = response ,
577+ metadata = metadata ,
560578 )
561579
562580 # Done; return the response.
@@ -665,7 +683,12 @@ def sample_update_dataset():
665683 )
666684
667685 # Send the request.
668- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
686+ response = await rpc (
687+ request ,
688+ retry = retry ,
689+ timeout = timeout ,
690+ metadata = metadata ,
691+ )
669692
670693 # Done; return the response.
671694 return response
@@ -787,7 +810,12 @@ def sample_delete_dataset():
787810 )
788811
789812 # Send the request.
790- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
813+ response = await rpc (
814+ request ,
815+ retry = retry ,
816+ timeout = timeout ,
817+ metadata = metadata ,
818+ )
791819
792820 # Wrap the response in an operation future.
793821 response = operation_async .from_gapic (
@@ -928,7 +956,12 @@ def sample_import_data():
928956 )
929957
930958 # Send the request.
931- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
959+ response = await rpc (
960+ request ,
961+ retry = retry ,
962+ timeout = timeout ,
963+ metadata = metadata ,
964+ )
932965
933966 # Wrap the response in an operation future.
934967 response = operation_async .from_gapic (
@@ -1061,7 +1094,12 @@ def sample_export_data():
10611094 )
10621095
10631096 # Send the request.
1064- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1097+ response = await rpc (
1098+ request ,
1099+ retry = retry ,
1100+ timeout = timeout ,
1101+ metadata = metadata ,
1102+ )
10651103
10661104 # Wrap the response in an operation future.
10671105 response = operation_async .from_gapic (
@@ -1167,7 +1205,12 @@ def sample_get_annotation_spec():
11671205 )
11681206
11691207 # Send the request.
1170- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1208+ response = await rpc (
1209+ request ,
1210+ retry = retry ,
1211+ timeout = timeout ,
1212+ metadata = metadata ,
1213+ )
11711214
11721215 # Done; return the response.
11731216 return response
@@ -1278,7 +1321,12 @@ def sample_create_model():
12781321 )
12791322
12801323 # Send the request.
1281- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1324+ response = await rpc (
1325+ request ,
1326+ retry = retry ,
1327+ timeout = timeout ,
1328+ metadata = metadata ,
1329+ )
12821330
12831331 # Wrap the response in an operation future.
12841332 response = operation_async .from_gapic (
@@ -1384,7 +1432,12 @@ def sample_get_model():
13841432 )
13851433
13861434 # Send the request.
1387- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1435+ response = await rpc (
1436+ request ,
1437+ retry = retry ,
1438+ timeout = timeout ,
1439+ metadata = metadata ,
1440+ )
13881441
13891442 # Done; return the response.
13901443 return response
@@ -1488,12 +1541,20 @@ def sample_list_models():
14881541 )
14891542
14901543 # Send the request.
1491- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1544+ response = await rpc (
1545+ request ,
1546+ retry = retry ,
1547+ timeout = timeout ,
1548+ metadata = metadata ,
1549+ )
14921550
14931551 # This method is paged; wrap the response in a pager, which provides
14941552 # an `__aiter__` convenience method.
14951553 response = pagers .ListModelsAsyncPager (
1496- method = rpc , request = request , response = response , metadata = metadata ,
1554+ method = rpc ,
1555+ request = request ,
1556+ response = response ,
1557+ metadata = metadata ,
14971558 )
14981559
14991560 # Done; return the response.
@@ -1615,7 +1676,12 @@ def sample_delete_model():
16151676 )
16161677
16171678 # Send the request.
1618- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1679+ response = await rpc (
1680+ request ,
1681+ retry = retry ,
1682+ timeout = timeout ,
1683+ metadata = metadata ,
1684+ )
16191685
16201686 # Wrap the response in an operation future.
16211687 response = operation_async .from_gapic (
@@ -1724,7 +1790,12 @@ def sample_update_model():
17241790 )
17251791
17261792 # Send the request.
1727- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1793+ response = await rpc (
1794+ request ,
1795+ retry = retry ,
1796+ timeout = timeout ,
1797+ metadata = metadata ,
1798+ )
17281799
17291800 # Done; return the response.
17301801 return response
@@ -1845,7 +1916,12 @@ def sample_deploy_model():
18451916 )
18461917
18471918 # Send the request.
1848- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
1919+ response = await rpc (
1920+ request ,
1921+ retry = retry ,
1922+ timeout = timeout ,
1923+ metadata = metadata ,
1924+ )
18491925
18501926 # Wrap the response in an operation future.
18511927 response = operation_async .from_gapic (
@@ -1969,7 +2045,12 @@ def sample_undeploy_model():
19692045 )
19702046
19712047 # Send the request.
1972- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
2048+ response = await rpc (
2049+ request ,
2050+ retry = retry ,
2051+ timeout = timeout ,
2052+ metadata = metadata ,
2053+ )
19732054
19742055 # Wrap the response in an operation future.
19752056 response = operation_async .from_gapic (
@@ -2108,7 +2189,12 @@ def sample_export_model():
21082189 )
21092190
21102191 # Send the request.
2111- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
2192+ response = await rpc (
2193+ request ,
2194+ retry = retry ,
2195+ timeout = timeout ,
2196+ metadata = metadata ,
2197+ )
21122198
21132199 # Wrap the response in an operation future.
21142200 response = operation_async .from_gapic (
@@ -2214,7 +2300,12 @@ def sample_get_model_evaluation():
22142300 )
22152301
22162302 # Send the request.
2217- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
2303+ response = await rpc (
2304+ request ,
2305+ retry = retry ,
2306+ timeout = timeout ,
2307+ metadata = metadata ,
2308+ )
22182309
22192310 # Done; return the response.
22202311 return response
@@ -2343,12 +2434,20 @@ def sample_list_model_evaluations():
23432434 )
23442435
23452436 # Send the request.
2346- response = await rpc (request , retry = retry , timeout = timeout , metadata = metadata ,)
2437+ response = await rpc (
2438+ request ,
2439+ retry = retry ,
2440+ timeout = timeout ,
2441+ metadata = metadata ,
2442+ )
23472443
23482444 # This method is paged; wrap the response in a pager, which provides
23492445 # an `__aiter__` convenience method.
23502446 response = pagers .ListModelEvaluationsAsyncPager (
2351- method = rpc , request = request , response = response , metadata = metadata ,
2447+ method = rpc ,
2448+ request = request ,
2449+ response = response ,
2450+ metadata = metadata ,
23522451 )
23532452
23542453 # Done; return the response.
@@ -2363,7 +2462,9 @@ async def __aexit__(self, exc_type, exc, tb):
23632462
23642463try :
23652464 DEFAULT_CLIENT_INFO = gapic_v1 .client_info .ClientInfo (
2366- gapic_version = pkg_resources .get_distribution ("google-cloud-automl" ,).version ,
2465+ gapic_version = pkg_resources .get_distribution (
2466+ "google-cloud-automl" ,
2467+ ).version ,
23672468 )
23682469except pkg_resources .DistributionNotFound :
23692470 DEFAULT_CLIENT_INFO = gapic_v1 .client_info .ClientInfo ()
0 commit comments