mengqiankang 1 місяць тому
батько
коміт
b9721dbdea
2 змінених файлів з 4 додано та 6 видалено
  1. 2 2
      alien_util/celery_app.py
  2. 2 4
      alien_util/redis_client.py

+ 2 - 2
alien_util/celery_app.py

@@ -19,13 +19,13 @@ celery_app.conf.update(
     enable_utc=True,
     broker_transport_options={
         "master_name": settings.REDIS_MASTER_NAME,
-        "sentinel_kwargs": {"password": settings.REDIS_PASSWORD},
+        "sentinel_kwargs": {},
         "password": settings.REDIS_PASSWORD,
         "db": settings.REDIS_DB,
     },
     result_backend_transport_options={
         "master_name": settings.REDIS_MASTER_NAME,
-        "sentinel_kwargs": {"password": settings.REDIS_PASSWORD},
+        "sentinel_kwargs": {},
         "password": settings.REDIS_PASSWORD,
         "db": settings.REDIS_DB,
     },

+ 2 - 4
alien_util/redis_client.py

@@ -7,10 +7,8 @@ from alien_gateway.config import settings
 
 
 def _sentinel_kwargs() -> dict:
-    kwargs = {}
-    if settings.REDIS_PASSWORD:
-        kwargs["password"] = settings.REDIS_PASSWORD
-    return kwargs
+    """sentinel 本身无密码,此处不传 password"""
+    return {}
 
 
 def get_sentinel_client() -> Sentinel: