Skip to content
Snippets Groups Projects
Commit afc2f392 authored by Erwan Rouchet's avatar Erwan Rouchet
Browse files

Merge branch 'corpus-delete-retry' into 'master'

Add retries to corpus_delete

Closes #1308

See merge request !1775
parents 64d025ad 04f55f47
No related branches found
No related tags found
1 merge request!1775Add retries to corpus_delete
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment