Never retry bulk import tasks

OpenConceptLab · Nov 19, 2023 · ce87508 · ce87508
1 parent 61d1164
commit ce87508
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/common/tasks.py b/core/common/tasks.py
@@ -233,13 +233,13 @@ def __run_search_index_command(command, app_names=None):
         call_command('search_index', command, '-f', '--parallel')
 
 
-@app.task(base=QueueOnce)
+@app.task(base=QueueOnce, retry_kwargs={'max_retries': 0})
 def bulk_import(to_import, username, update_if_exists):
     from core.importers.models import BulkImport
     return BulkImport(content=to_import, username=username, update_if_exists=update_if_exists).run()
 
 
-@app.task(base=QueueOnce, bind=True)
+@app.task(base=QueueOnce, bind=True, retry_kwargs={'max_retries': 0})
 def bulk_import_parallel_inline(self, to_import, username, update_if_exists, threads=5):
     from core.importers.models import BulkImportParallelRunner
     try:
@@ -254,13 +254,13 @@ def bulk_import_parallel_inline(self, to_import, username, update_if_exists, thr
     return importer.run()
 
 
-@app.task(base=QueueOnce)
+@app.task(base=QueueOnce, retry_kwargs={'max_retries': 0})
 def bulk_import_inline(to_import, username, update_if_exists):
     from core.importers.models import BulkImportInline
     return BulkImportInline(content=to_import, username=username, update_if_exists=update_if_exists).run()
 
 
-@app.task(bind=True)
+@app.task(bind=True, retry_kwargs={'max_retries': 0})
 def bulk_import_parts_inline(self, input_list, username, update_if_exists):
     from core.importers.models import BulkImportInline
     return BulkImportInline(