()
| 137 | |
| 138 | |
| 139 | def test_default_retry_config(): |
| 140 | sync_retry = inspect.signature(Redis.__init__).parameters["retry"].default |
| 141 | assert isinstance(sync_retry, Retry) |
| 142 | assert sync_retry.get_retries() == 10 |
| 143 | assert isinstance(sync_retry._backoff, ExponentialWithJitterBackoff) |
| 144 | assert sync_retry._backoff._base == 0.01 |
| 145 | assert sync_retry._backoff._cap == 1 |
| 146 | |
| 147 | async_retry = inspect.signature(AsyncRedis.__init__).parameters["retry"].default |
| 148 | assert isinstance(async_retry, AsyncRetry) |
| 149 | assert async_retry.get_retries() == 10 |
| 150 | assert isinstance(async_retry._backoff, ExponentialWithJitterBackoff) |
| 151 | assert async_retry._backoff._base == 0.01 |
| 152 | assert async_retry._backoff._cap == 1 |
| 153 | |
| 154 | for cls in (RedisCluster, AsyncRedisCluster): |
| 155 | default = ( |
| 156 | inspect.signature(cls.__init__) |
| 157 | .parameters["cluster_error_retry_attempts"] |
| 158 | .default |
| 159 | ) |
| 160 | assert default == 10 |
| 161 | |
| 162 | |
| 163 | def test_default_socket_keepalive_options(): |
nothing calls this directly
no test coverage detected