added retry on failure for source mappings index task

OpenConceptLab · Apr 1, 2022 · b1c4851 · b1c4851
1 parent 58fe607
commit b1c4851
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/common/tasks.py b/core/common/tasks.py
@@ -573,7 +573,10 @@ def index_source_concepts(source_id):
         source.batch_index(source.concepts, ConceptDocument)
 
 
-@app.task
+@app.task(
+    ignore_result=True, autoretry_for=(Exception, WorkerLostError, ), retry_kwargs={'max_retries': 2, 'countdown': 2},
+    acks_late=True, reject_on_worker_lost=True
+)
 def index_source_mappings(source_id):
     from core.sources.models import Source
     source = Source.objects.filter(id=source_id).first()