highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-04-08 11:58:34 +02:00
Code Issues Packages Projects Releases Wiki Activity

ensure tenant id passed

Browse Source
This commit is contained in:
pablodanswer 2024-10-19 18:00:30 -07:00
parent c39f590d0d
commit 75c5de802b
3 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/danswer/background/celery/tasks/indexing/tasks.py
View File

@ -54,7 +54,7 @@ logger = setup_logger()
def check_for_indexing(tenant_id: str | None) -> int | None:
tasks_created = 0
r = get_redis_client()
r = get_redis_client(tenant_id)
lock_beat = r.lock(
DanswerRedisLocks.CHECK_INDEXING_BEAT_LOCK,
@ -370,7 +370,7 @@ def connector_indexing_task(
attempt = None
n_final_progress = 0
r = get_redis_client()
r = get_redis_client(tenant_id)
rci = RedisConnectorIndexing(cc_pair_id, search_settings_id)

2
backend/danswer/redis/redis_pool.py
View File

@ -134,7 +134,7 @@ class RedisPool:
redis_pool = RedisPool()
def get_redis_client(tenant_id: str | None = None) -> Redis:
def get_redis_client(tenant_id: str | None) -> Redis:
return redis_pool.get_client(tenant_id)

3
backend/danswer/server/documents/credential.py
View File

@ -137,9 +137,6 @@ def create_credential_from_model(
target_group_ids=credential_info.groups,
object_is_public=credential_info.curator_public,
)
from danswer.db.models import Credential
db_session.query(Credential).all()
credential = create_credential(credential_info, user, db_session)
return ObjectCreationIdResponse(