|
32 | 32 | import datetime |
33 | 33 | import pytest |
34 | 34 |
|
35 | | -from test_utils.system import unique_resource_id |
36 | | -from test_utils.retry import RetryErrors |
| 35 | +from google.api_core.exceptions import DeadlineExceeded |
37 | 36 | from google.api_core.exceptions import NotFound |
38 | 37 | from google.api_core.exceptions import TooManyRequests |
39 | | -from google.api_core.exceptions import DeadlineExceeded |
| 38 | +from google.api_core.exceptions import ServiceUnavailable |
| 39 | +from test_utils.system import unique_resource_id |
| 40 | +from test_utils.retry import RetryErrors |
| 41 | + |
40 | 42 | from google.cloud._helpers import UTC |
41 | 43 | from google.cloud.bigtable import Client |
42 | 44 | from google.cloud.bigtable import enums |
|
62 | 64 | LABELS = {LABEL_KEY: str(LABEL_STAMP)} |
63 | 65 | INSTANCES_TO_DELETE = [] |
64 | 66 |
|
65 | | -retry_429 = RetryErrors(TooManyRequests, max_tries=9) |
| 67 | +retry_429_503 = RetryErrors((ServiceUnavailable, TooManyRequests), max_tries=9) |
66 | 68 | retry_504 = RetryErrors(DeadlineExceeded, max_tries=4) |
67 | 69 |
|
68 | 70 |
|
@@ -97,11 +99,11 @@ def setup_module(): |
97 | 99 |
|
98 | 100 |
|
99 | 101 | def teardown_module(): |
100 | | - retry_429(Config.INSTANCE.delete)() |
| 102 | + retry_429_503(Config.INSTANCE.delete)() |
101 | 103 |
|
102 | 104 | for instance in INSTANCES_TO_DELETE: |
103 | 105 | try: |
104 | | - retry_429(instance.delete)() |
| 106 | + retry_429_503(instance.delete)() |
105 | 107 | except NotFound: |
106 | 108 | pass |
107 | 109 |
|
@@ -137,7 +139,7 @@ def test_bigtable_create_instance(): |
137 | 139 | try: |
138 | 140 | assert instance.exists() |
139 | 141 | finally: |
140 | | - retry_429(instance.delete)() |
| 142 | + retry_429_503(instance.delete)() |
141 | 143 |
|
142 | 144 |
|
143 | 145 | def test_bigtable_create_additional_cluster(): |
@@ -172,7 +174,7 @@ def test_bigtable_create_additional_cluster(): |
172 | 174 | try: |
173 | 175 | assert cluster.exists() |
174 | 176 | finally: |
175 | | - retry_429(cluster.delete)() |
| 177 | + retry_429_503(cluster.delete)() |
176 | 178 |
|
177 | 179 |
|
178 | 180 | def test_bigtable_create_reload_delete_app_profile(): |
@@ -318,7 +320,7 @@ def test_bigtable_list_app_profiles(): |
318 | 320 | try: |
319 | 321 | assert len(app_profiles_list) > 0 |
320 | 322 | finally: |
321 | | - retry_429(app_profile.delete)(ignore_warnings=True) |
| 323 | + retry_429_503(app_profile.delete)(ignore_warnings=True) |
322 | 324 |
|
323 | 325 |
|
324 | 326 | def test_bigtable_instance_exists(): |
@@ -423,7 +425,7 @@ def test_bigtable_create_table(): |
423 | 425 | try: |
424 | 426 | assert table.exists() |
425 | 427 | finally: |
426 | | - retry_429(table.delete)() |
| 428 | + retry_429_503(table.delete)() |
427 | 429 |
|
428 | 430 |
|
429 | 431 | def test_bigtable_list_tables(): |
|
0 commit comments