From e481a2e4635dfd77325778851b49011d9891ca8c Mon Sep 17 00:00:00 2001
From: Erwan Rouchet <rouchet@teklia.com>
Date: Mon, 24 Jan 2022 11:18:00 +0100
Subject: [PATCH] Allow some retries on initialize_activity
---
arkindex/dataimport/tasks.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/arkindex/dataimport/tasks.py b/arkindex/dataimport/tasks.py
index a0c6601c45..ec440f4902 100644
--- a/arkindex/dataimport/tasks.py
+++ b/arkindex/dataimport/tasks.py
@@ -3,15 +3,16 @@ from typing import Optional
from django.conf import settings
from django.db import transaction
from django_rq import job
+from rq import Retry
from arkindex.dataimport.models import ActivityState, DataImport, WorkerActivity, WorkerActivityState
-@job('default', timeout=settings.RQ_TIMEOUTS['initialize_activity'])
+@job('default', timeout=settings.RQ_TIMEOUTS['initialize_activity'], retry=Retry(max=4))
def initialize_activity(process: DataImport):
"""
List all worker versions used in a process and initialize their activity on processed elements.
- Timeout is set to 1 hour
+ 4 retries allowed, for a total of 5 attempts, to try to mitigate some database errors from the large query.
"""
try:
with transaction.atomic():
--
GitLab