3333from google .api_core .client_options import ClientOptions
3434from google .api_core import exceptions as core_exceptions
3535from google .api_core import gapic_v1
36- from google .api_core import retry as retries
36+ from google .api_core import retry_async as retries
3737from google .auth import credentials as ga_credentials # type: ignore
3838from google .oauth2 import service_account # type: ignore
3939
4040try :
41- OptionalRetry = Union [retries .Retry , gapic_v1 .method ._MethodDefault ]
41+ OptionalRetry = Union [retries .AsyncRetry , gapic_v1 .method ._MethodDefault ]
4242except AttributeError : # pragma: NO COVER
43- OptionalRetry = Union [retries .Retry , object ] # type: ignore
43+ OptionalRetry = Union [retries .AsyncRetry , object ] # type: ignore
4444
4545from google .api_core import operation # type: ignore
4646from google .api_core import operation_async # type: ignore
@@ -305,7 +305,7 @@ async def create_instance(
305305 This corresponds to the ``clusters`` field
306306 on the ``request`` instance; if ``request`` is provided, this
307307 should not be set.
308- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
308+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
309309 should be retried.
310310 timeout (float): The timeout for this request.
311311 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -404,7 +404,7 @@ async def get_instance(
404404 This corresponds to the ``name`` field
405405 on the ``request`` instance; if ``request`` is provided, this
406406 should not be set.
407- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
407+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
408408 should be retried.
409409 timeout (float): The timeout for this request.
410410 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -440,7 +440,7 @@ async def get_instance(
440440 # and friendly error handling.
441441 rpc = gapic_v1 .method_async .wrap_method (
442442 self ._client ._transport .get_instance ,
443- default_retry = retries .Retry (
443+ default_retry = retries .AsyncRetry (
444444 initial = 1.0 ,
445445 maximum = 60.0 ,
446446 multiplier = 2 ,
@@ -496,7 +496,7 @@ async def list_instances(
496496 This corresponds to the ``parent`` field
497497 on the ``request`` instance; if ``request`` is provided, this
498498 should not be set.
499- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
499+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
500500 should be retried.
501501 timeout (float): The timeout for this request.
502502 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -529,7 +529,7 @@ async def list_instances(
529529 # and friendly error handling.
530530 rpc = gapic_v1 .method_async .wrap_method (
531531 self ._client ._transport .list_instances ,
532- default_retry = retries .Retry (
532+ default_retry = retries .AsyncRetry (
533533 initial = 1.0 ,
534534 maximum = 60.0 ,
535535 multiplier = 2 ,
@@ -581,7 +581,7 @@ async def update_instance(
581581 served from all
582582 [Clusters][google.bigtable.admin.v2.Cluster] in the
583583 instance.
584- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
584+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
585585 should be retried.
586586 timeout (float): The timeout for this request.
587587 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -603,7 +603,7 @@ async def update_instance(
603603 # and friendly error handling.
604604 rpc = gapic_v1 .method_async .wrap_method (
605605 self ._client ._transport .update_instance ,
606- default_retry = retries .Retry (
606+ default_retry = retries .AsyncRetry (
607607 initial = 1.0 ,
608608 maximum = 60.0 ,
609609 multiplier = 2 ,
@@ -669,7 +669,7 @@ async def partial_update_instance(
669669 This corresponds to the ``update_mask`` field
670670 on the ``request`` instance; if ``request`` is provided, this
671671 should not be set.
672- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
672+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
673673 should be retried.
674674 timeout (float): The timeout for this request.
675675 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -709,7 +709,7 @@ async def partial_update_instance(
709709 # and friendly error handling.
710710 rpc = gapic_v1 .method_async .wrap_method (
711711 self ._client ._transport .partial_update_instance ,
712- default_retry = retries .Retry (
712+ default_retry = retries .AsyncRetry (
713713 initial = 1.0 ,
714714 maximum = 60.0 ,
715715 multiplier = 2 ,
@@ -775,7 +775,7 @@ async def delete_instance(
775775 This corresponds to the ``name`` field
776776 on the ``request`` instance; if ``request`` is provided, this
777777 should not be set.
778- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
778+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
779779 should be retried.
780780 timeout (float): The timeout for this request.
781781 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -869,7 +869,7 @@ async def create_cluster(
869869 This corresponds to the ``cluster`` field
870870 on the ``request`` instance; if ``request`` is provided, this
871871 should not be set.
872- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
872+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
873873 should be retried.
874874 timeout (float): The timeout for this request.
875875 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -964,7 +964,7 @@ async def get_cluster(
964964 This corresponds to the ``name`` field
965965 on the ``request`` instance; if ``request`` is provided, this
966966 should not be set.
967- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
967+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
968968 should be retried.
969969 timeout (float): The timeout for this request.
970970 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -999,7 +999,7 @@ async def get_cluster(
999999 # and friendly error handling.
10001000 rpc = gapic_v1 .method_async .wrap_method (
10011001 self ._client ._transport .get_cluster ,
1002- default_retry = retries .Retry (
1002+ default_retry = retries .AsyncRetry (
10031003 initial = 1.0 ,
10041004 maximum = 60.0 ,
10051005 multiplier = 2 ,
@@ -1057,7 +1057,7 @@ async def list_clusters(
10571057 This corresponds to the ``parent`` field
10581058 on the ``request`` instance; if ``request`` is provided, this
10591059 should not be set.
1060- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1060+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
10611061 should be retried.
10621062 timeout (float): The timeout for this request.
10631063 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1090,7 +1090,7 @@ async def list_clusters(
10901090 # and friendly error handling.
10911091 rpc = gapic_v1 .method_async .wrap_method (
10921092 self ._client ._transport .list_clusters ,
1093- default_retry = retries .Retry (
1093+ default_retry = retries .AsyncRetry (
10941094 initial = 1.0 ,
10951095 maximum = 60.0 ,
10961096 multiplier = 2 ,
@@ -1141,7 +1141,7 @@ async def update_cluster(
11411141 location, capable of serving all
11421142 [Tables][google.bigtable.admin.v2.Table] in the parent
11431143 [Instance][google.bigtable.admin.v2.Instance].
1144- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1144+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
11451145 should be retried.
11461146 timeout (float): The timeout for this request.
11471147 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1164,7 +1164,7 @@ async def update_cluster(
11641164 # and friendly error handling.
11651165 rpc = gapic_v1 .method_async .wrap_method (
11661166 self ._client ._transport .update_cluster ,
1167- default_retry = retries .Retry (
1167+ default_retry = retries .AsyncRetry (
11681168 initial = 1.0 ,
11691169 maximum = 60.0 ,
11701170 multiplier = 2 ,
@@ -1248,7 +1248,7 @@ async def partial_update_cluster(
12481248 This corresponds to the ``update_mask`` field
12491249 on the ``request`` instance; if ``request`` is provided, this
12501250 should not be set.
1251- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1251+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
12521252 should be retried.
12531253 timeout (float): The timeout for this request.
12541254 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1343,7 +1343,7 @@ async def delete_cluster(
13431343 This corresponds to the ``name`` field
13441344 on the ``request`` instance; if ``request`` is provided, this
13451345 should not be set.
1346- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1346+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
13471347 should be retried.
13481348 timeout (float): The timeout for this request.
13491349 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1431,7 +1431,7 @@ async def create_app_profile(
14311431 This corresponds to the ``app_profile`` field
14321432 on the ``request`` instance; if ``request`` is provided, this
14331433 should not be set.
1434- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1434+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
14351435 should be retried.
14361436 timeout (float): The timeout for this request.
14371437 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1515,7 +1515,7 @@ async def get_app_profile(
15151515 This corresponds to the ``name`` field
15161516 on the ``request`` instance; if ``request`` is provided, this
15171517 should not be set.
1518- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1518+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
15191519 should be retried.
15201520 timeout (float): The timeout for this request.
15211521 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1549,7 +1549,7 @@ async def get_app_profile(
15491549 # and friendly error handling.
15501550 rpc = gapic_v1 .method_async .wrap_method (
15511551 self ._client ._transport .get_app_profile ,
1552- default_retry = retries .Retry (
1552+ default_retry = retries .AsyncRetry (
15531553 initial = 1.0 ,
15541554 maximum = 60.0 ,
15551555 multiplier = 2 ,
@@ -1608,7 +1608,7 @@ async def list_app_profiles(
16081608 This corresponds to the ``parent`` field
16091609 on the ``request`` instance; if ``request`` is provided, this
16101610 should not be set.
1611- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1611+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
16121612 should be retried
1241
.
16131613 timeout (float): The timeout for this request.
16141614 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1644,7 +1644,7 @@ async def list_app_profiles(
16441644 # and friendly error handling.
16451645 rpc = gapic_v1 .method_async .wrap_method (
16461646 self ._client ._transport .list_app_profiles ,
1647- default_retry = retries .Retry (
1647+ default_retry = retries .AsyncRetry (
16481648 initial = 1.0 ,
16491649 maximum = 60.0 ,
16501650 multiplier = 2 ,
@@ -1717,7 +1717,7 @@ async def update_app_profile(
17171717 This corresponds to the ``update_mask`` field
17181718 on the ``request`` instance; if ``request`` is provided, this
17191719 should not be set.
1720- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1720+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
17211721 should be retried.
17221722 timeout (float): The timeout for this request.
17231723 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1754,7 +1754,7 @@ async def update_app_profile(
17541754 # and friendly error handling.
17551755 rpc = gapic_v1 .method_async .wrap_method (
17561756 self ._client ._transport .update_app_profile ,
1757- default_retry = retries .Retry (
1757+ default_retry = retries .AsyncRetry (
17581758 initial = 1.0 ,
17591759 maximum = 60.0 ,
17601760 multiplier = 2 ,
@@ -1820,7 +1820,7 @@ async def delete_app_profile(
18201820 This corresponds to the ``name`` field
18211821 on the ``request`` instance; if ``request`` is provided, this
18221822 should not be set.
1823- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
1823+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
18241824 should be retried.
18251825 timeout (float): The timeout for this request.
18261826 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1890,7 +1890,7 @@ async def get_iam_policy(
18901890 This corresponds to the ``resource`` field
18911891 on the ``request`` instance; if ``request`` is provided, this
18921892 should not be set.
1893- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
10000
1893+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
18941894 should be retried.
18951895 timeout (float): The timeout for this request.
18961896 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -1953,7 +1953,7 @@ async def get_iam_policy(
19531953 # and friendly error handling.
19541954 rpc = gapic_v1 .method_async .wrap_method (
19551955 self ._client ._transport .get_iam_policy ,
1956- default_retry = retries .Retry (
1956+ default_retry = retries .AsyncRetry (
19571957 initial = 1.0 ,
19581958 maximum = 60.0 ,
19591959 multiplier = 2 ,
@@ -2008,7 +2008,7 @@ async def set_iam_policy(
20082008 This corresponds to the ``resource`` field
20092009 on the ``request`` instance; if ``request`` is provided, this
20102010 should not be set.
2011- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
2011+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
20122012 should be retried.
20132013 timeout (float): The timeout for this request.
20142014 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -2126,7 +2126,7 @@ async def test_iam_permissions(
21262126 This corresponds to the ``permissions`` field
21272127 on the ``request`` instance; if ``request`` is provided, this
21282128 should not be set.
2129- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
2129+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
21302130 should be retried.
21312131 timeout (float): The timeout for this request.
21322132 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -2160,7 +2160,7 @@ async def test_iam_permissions(
21602160 # and friendly error handling.
21612161 rpc = gapic_v1 .method_async .wrap_method (
21622162 self ._client ._transport .test_iam_permissions ,
2163- default_retry = retries .Retry (
2163+ default_retry = retries .AsyncRetry (
21642164 initial = 1.0 ,
21652165 maximum = 60.0 ,
21662166 multiplier = 2 ,
@@ -2217,7 +2217,7 @@ async def list_hot_tablets(
22172217 This corresponds to the ``parent`` field
22182218 on the ``r
8F3F
equest`` instance; if ``request`` is provided, this
22192219 should not be set.
2220- retry (google.api_core.retry.Retry ): Designation of what errors, if any,
2220+ retry (google.api_core.retry_async.AsyncRetry ): Designation of what errors, if any,
22212221 should be retried.
22222222 timeout (float): The timeout for this request.
22232223 metadata (Sequence[Tuple[str, str]]): Strings which should be
@@ -2253,7 +2253,7 @@ async def list_hot_tablets(
22532253 # and friendly error handling.
22542254 rpc = gapic_v1 .method_async .wrap_method (
22552255 self ._client ._transport .list_hot_tablets ,
2256- default_retry = retries .Retry (
2256+ default_retry = retries .AsyncRetry (
22572257 initial = 1.0 ,
22582258 maximum = 60.0 ,
22592259 multiplier = 2 ,
0 commit comments