k

danswer-ai · Nov 9, 2024 · 0f605a8 · 0f605a8
1 parent 9640442
commit 0f605a8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/backend/danswer/redis/redis_document_set.py b/backend/danswer/redis/redis_document_set.py
@@ -9,6 +9,7 @@
 
 from danswer.configs.constants import CELERY_VESPA_SYNC_BEAT_LOCK_TIMEOUT
 from danswer.configs.constants import DanswerCeleryPriority
+from danswer.configs.constants import DanswerCeleryQueues
 from danswer.db.document_set import construct_document_select_by_docset
 from danswer.redis.redis_object_helper import RedisObjectHelper
 
@@ -76,7 +77,7 @@ def generate_tasks(
             result = celery_app.send_task(
                 "vespa_metadata_sync_task",
                 kwargs=dict(document_id=doc.id, tenant_id=tenant_id),
-                queue="zzzzzz",
+                queue=DanswerCeleryQueues.VESPA_METADATA_SYNC,
                 task_id=custom_task_id,
                 priority=DanswerCeleryPriority.LOW,
             )