|
16 | 16 | from redis.multidb.exception import UnhealthyDatabaseException |
17 | 17 |
|
18 | 18 |
|
| 19 | +@pytest.mark.onlynoncluster |
19 | 20 | class TestHealthyAllPolicy: |
20 | 21 | @pytest.mark.asyncio |
21 | 22 | async def test_policy_returns_true_for_all_successful_probes(self): |
@@ -58,6 +59,7 @@ async def test_policy_raise_unhealthy_database_exception(self): |
58 | 59 | assert mock_hc2.check_health.call_count == 0 |
59 | 60 |
|
60 | 61 |
|
| 62 | +@pytest.mark.onlynoncluster |
61 | 63 | class TestHealthyMajorityPolicy: |
62 | 64 | @pytest.mark.asyncio |
63 | 65 | @pytest.mark.parametrize( |
@@ -151,6 +153,7 @@ async def test_policy_raise_unhealthy_database_exception_on_majority_probes_exce |
151 | 153 | assert mock_hc2.check_health.call_count == hc2_call_count |
152 | 154 |
|
153 | 155 |
|
| 156 | +@pytest.mark.onlynoncluster |
154 | 157 | class TestHealthyAnyPolicy: |
155 | 158 | @pytest.mark.asyncio |
156 | 159 | @pytest.mark.parametrize( |
@@ -204,6 +207,7 @@ async def test_policy_raise_unhealthy_database_exception_if_exception_occurs_on_ |
204 | 207 | assert mock_hc2.check_health.call_count == 0 |
205 | 208 |
|
206 | 209 |
|
| 210 | +@pytest.mark.onlynoncluster |
207 | 211 | class TestEchoHealthCheck: |
208 | 212 | @pytest.mark.asyncio |
209 | 213 | async def test_database_is_healthy_on_echo_response(self, mock_client, mock_cb): |
@@ -246,6 +250,7 @@ async def test_database_close_circuit_on_successful_healthcheck( |
246 | 250 | assert mock_client.execute_command.call_count == 1 |
247 | 251 |
|
248 | 252 |
|
| 253 | +@pytest.mark.onlynoncluster |
249 | 254 | class TestLagAwareHealthCheck: |
250 | 255 | @pytest.mark.asyncio |
251 | 256 | async def test_database_is_healthy_when_bdb_matches_by_dns_name( |
|
0 commit comments