Sfoglia il codice sorgente

retry on any redis error

Masen Furer 4 mesi fa
parent
commit
7419efeae3
1 ha cambiato i file con 2 aggiunte e 2 eliminazioni
  1. 2 2
      reflex/utils/prerequisites.py

+ 2 - 2
reflex/utils/prerequisites.py

@@ -30,7 +30,7 @@ from packaging import version
 from redis import Redis as RedisSync
 from redis import Redis as RedisSync
 from redis.asyncio import Redis
 from redis.asyncio import Redis
 from redis.backoff import ExponentialBackoff
 from redis.backoff import ExponentialBackoff
-from redis.exceptions import BusyLoadingError, ConnectionError, RedisError, TimeoutError
+from redis.exceptions import RedisError
 from redis.retry import Retry
 from redis.retry import Retry
 
 
 from reflex import constants, model
 from reflex import constants, model
@@ -332,7 +332,7 @@ def get_compiled_app(reload: bool = False, export: bool = False) -> ModuleType:
 def _get_common_redis_kwargs() -> dict[str, Any]:
 def _get_common_redis_kwargs() -> dict[str, Any]:
     return {
     return {
         "retry": Retry(ExponentialBackoff(), 3),
         "retry": Retry(ExponentialBackoff(), 3),
-        "retry_on_error": [BusyLoadingError, ConnectionError, TimeoutError],
+        "retry_on_error": [RedisError],
     }
     }