Retry routing task 5 times when signal is locked

delta10 · Apr 7, 2023 · b907e5c · b907e5c
1 parent 9b3f948
commit b907e5c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/app/signals/apps/signals/tasks.py b/app/signals/apps/signals/tasks.py
@@ -5,6 +5,7 @@
 from django.db import connection
 from django.db.models import Q
 from django.utils import timezone
+from psycopg2.errors import LockNotAvailable
 
 from signals.apps.services.domain.auto_create_children.service import AutoCreateChildrenService
 from signals.apps.services.domain.delete_signals import SignalDeletionService
@@ -23,7 +24,7 @@
 dsl_service = SignalDslService()
 
 
-@app.task
+@app.task(autoretry_for=(LockNotAvailable, ), max_retries=5, default_retry_delay=5)
 def apply_routing(signal_id):
     signal = Signal.objects.get(pk=signal_id)
     dsl_service.process_routing_rules(signal)