From 5b8fbada11dcf350757ea91eecf920831eda2217 Mon Sep 17 00:00:00 2001 From: Martyn Inglis Date: Wed, 10 Aug 2016 08:46:37 +0100 Subject: [PATCH] Extend the retry time on the create notification DB tasks - Was previoulsy 5 attempts 5 seconds apart - No 5 times 5 minutes apart. - Gives 25 mins of retries before an error --- app/celery/tasks.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/celery/tasks.py b/app/celery/tasks.py index bdcb37327..df8c52333 100644 --- a/app/celery/tasks.py +++ b/app/celery/tasks.py @@ -126,7 +126,7 @@ def remove_job(job_id): current_app.logger.info("Job {} has been removed from s3.".format(job_id)) -@notify_celery.task(bind=True, name="send-sms", max_retries=5, default_retry_delay=5) +@notify_celery.task(bind=True, name="send-sms", max_retries=5, default_retry_delay=300) @statsd(namespace="tasks") def send_sms(self, service_id, @@ -158,7 +158,7 @@ def send_sms(self, raise self.retry(queue="retry", exc=e) -@notify_celery.task(bind=True, name="send-email", max_retries=5, default_retry_delay=5) +@notify_celery.task(bind=True, name="send-email", max_retries=5, default_retry_delay=300) @statsd(namespace="tasks") def send_email(self, service_id, notification_id,