Retry routing task 5 times when signal is locked

app/signals/apps/signals/tasks.py

@@ -5,6 +5,7 @@
 from django.core.management import call_command
 from django.db import connection
 from django.db.models import Q
+from django.db.utils import OperationalError
 from django.utils import timezone
 
 from signals.apps.services.domain.auto_create_children.service import AutoCreateChildrenService
@@ -24,7 +25,8 @@
 dsl_service = SignalDslService()
 
 
-@app.task
+# OperationalError catches the psycopg2.errors.LockNotAvailable exception
+@app.task(autoretry_for=(OperationalError, ), max_retries=5, default_retry_delay=10)
 def apply_routing(signal_id):
     signal = Signal.objects.get(pk=signal_id)
     dsl_service.process_routing_rules(signal)