From 0c0113a481b5bc87de0d6f656a40a6fc4751e1e0 Mon Sep 17 00:00:00 2001 From: rkuo-danswer Date: Thu, 13 Feb 2025 03:22:13 -0800 Subject: [PATCH] ignore result when using send_task on lightweight tasks (#3978) * ignore result when using send_task on lightweight tasks * fix ignore_result --------- Co-authored-by: Richard Kuo (Danswer) Co-authored-by: Richard Kuo --- backend/onyx/background/celery/tasks/shared/tasks.py | 1 + backend/onyx/redis/redis_connector_credential_pair.py | 1 + backend/onyx/redis/redis_connector_delete.py | 1 + backend/onyx/redis/redis_connector_doc_perm_sync.py | 1 + backend/onyx/redis/redis_connector_prune.py | 1 + 5 files changed, 5 insertions(+) diff --git a/backend/onyx/background/celery/tasks/shared/tasks.py b/backend/onyx/background/celery/tasks/shared/tasks.py index 84f7e12c675..34ded164f9d 100644 --- a/backend/onyx/background/celery/tasks/shared/tasks.py +++ b/backend/onyx/background/celery/tasks/shared/tasks.py @@ -270,6 +270,7 @@ def cloud_beat_task_generator( queue=queue, priority=priority, expires=expires, + ignore_result=True, ) except SoftTimeLimitExceeded: task_logger.info( diff --git a/backend/onyx/redis/redis_connector_credential_pair.py b/backend/onyx/redis/redis_connector_credential_pair.py index 3738b10b8a9..463a0c1a240 100644 --- a/backend/onyx/redis/redis_connector_credential_pair.py +++ b/backend/onyx/redis/redis_connector_credential_pair.py @@ -120,6 +120,7 @@ def generate_tasks( queue=OnyxCeleryQueues.VESPA_METADATA_SYNC, task_id=custom_task_id, priority=OnyxCeleryPriority.MEDIUM, + ignore_result=True, ) num_tasks_sent += 1 diff --git a/backend/onyx/redis/redis_connector_delete.py b/backend/onyx/redis/redis_connector_delete.py index 3ac5edb7271..04eb459b0d5 100644 --- a/backend/onyx/redis/redis_connector_delete.py +++ b/backend/onyx/redis/redis_connector_delete.py @@ -132,6 +132,7 @@ def generate_tasks( queue=OnyxCeleryQueues.CONNECTOR_DELETION, task_id=custom_task_id, priority=OnyxCeleryPriority.MEDIUM, + ignore_result=True, ) async_results.append(result) diff --git a/backend/onyx/redis/redis_connector_doc_perm_sync.py b/backend/onyx/redis/redis_connector_doc_perm_sync.py index cc2716676ea..1dc8dfff578 100644 --- a/backend/onyx/redis/redis_connector_doc_perm_sync.py +++ b/backend/onyx/redis/redis_connector_doc_perm_sync.py @@ -196,6 +196,7 @@ def generate_tasks( queue=OnyxCeleryQueues.DOC_PERMISSIONS_UPSERT, task_id=custom_task_id, priority=OnyxCeleryPriority.HIGH, + ignore_result=True, ) async_results.append(result) diff --git a/backend/onyx/redis/redis_connector_prune.py b/backend/onyx/redis/redis_connector_prune.py index df401df5a6a..3a61c059d13 100644 --- a/backend/onyx/redis/redis_connector_prune.py +++ b/backend/onyx/redis/redis_connector_prune.py @@ -202,6 +202,7 @@ def generate_tasks( queue=OnyxCeleryQueues.CONNECTOR_DELETION, task_id=custom_task_id, priority=OnyxCeleryPriority.MEDIUM, + ignore_result=True, ) async_results.append(result)