Add retries to corpus_delete

arkindex/documents/tasks.py

@@ -5,7 +5,7 @@ from uuid import UUID
 from django.conf import settings
 from django.db.models import Q
 from django_rq import job
-from rq import get_current_job
+from rq import Retry, get_current_job
 
 from arkindex.dataimport.models import DataImport, DataImportElement, WorkerActivity, WorkerRun
 from arkindex.documents.managers import ElementQuerySet
@@ -24,7 +24,7 @@ from arkindex.documents.models import (
 logger = logging.getLogger(__name__)
 
 
-@job('high', timeout=settings.RQ_TIMEOUTS['corpus_delete'])
+@job('high', timeout=settings.RQ_TIMEOUTS['corpus_delete'], retry=Retry(max=3))
 def corpus_delete(corpus_id: str) -> None:
     # Note that this can be None when the task is run outside of a RQ worker (e.g. unit test)
     rq_job = get_current_job()