highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-09-20 13:05:49 +02:00
Code Issues Packages Projects Releases Wiki Activity

minor read replica fix (#3997)

Browse Source
This commit is contained in:
pablonyx
2025-02-13 17:11:45 -08:00
committed by GitHub
parent 35574369ed
commit e9492ce9ec
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
backend/ee/onyx/server/tenants/product_gating.py
View File

@@ -2,6 +2,7 @@ from typing import cast
from ee.onyx.configs.app_configs import GATED_TENANTS_KEY from ee.onyx.configs.app_configs import GATED_TENANTS_KEY
from onyx.configs.constants import ONYX_CLOUD_TENANT_ID from onyx.configs.constants import ONYX_CLOUD_TENANT_ID
from onyx.redis.redis_pool import get_redis_client
from onyx.redis.redis_pool import get_redis_replica_client from onyx.redis.redis_pool import get_redis_replica_client
from onyx.server.settings.models import ApplicationStatus from onyx.server.settings.models import ApplicationStatus
from onyx.server.settings.store import load_settings from onyx.server.settings.store import load_settings
@@ -13,7 +14,7 @@ logger = setup_logger()
def update_tenant_gating(tenant_id: str, status: ApplicationStatus) -> None: def update_tenant_gating(tenant_id: str, status: ApplicationStatus) -> None:
redis_client = get_redis_replica_client(tenant_id=ONYX_CLOUD_TENANT_ID) redis_client = get_redis_client(tenant_id=ONYX_CLOUD_TENANT_ID)
# Store the full status # Store the full status
status_key = f"tenant:{tenant_id}:status" status_key = f"tenant:{tenant_id}:status"