From 6eb7de0c4570b5a2cb51c936925cfdc1c7c3a160 Mon Sep 17 00:00:00 2001 From: Carlo Costino Date: Wed, 30 Jul 2025 11:33:23 -0400 Subject: [PATCH 1/3] Expose underlying error message in process delivery task This changeset adds error information to a log statement so we can have a better idea of what might be failing with the process delivery Celery task. Signed-off-by: Carlo Costino --- app/celery/scheduled_tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index ebc17c452..483dabd19 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -286,7 +286,7 @@ def process_delivery_receipts(self): raise self.retry(ex=ex, countdown=wait_time) except self.MaxRetriesExceededError: current_app.logger.error( - "Failed process delivery receipts after max retries" + f"Failed process delivery receipts after max retries: {str(ex)}" ) From 036817daf4cdc589e00f6a2e0baa6f7458fc9e4e Mon Sep 17 00:00:00 2001 From: Carlo Costino Date: Wed, 30 Jul 2025 11:47:18 -0400 Subject: [PATCH 2/3] Re-raise exception to see what is happening Signed-off-by: Carlo Costino --- app/celery/scheduled_tasks.py | 1 + 1 file changed, 1 insertion(+) diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index 483dabd19..9e3bccf8a 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -288,6 +288,7 @@ def process_delivery_receipts(self): current_app.logger.error( f"Failed process delivery receipts after max retries: {str(ex)}" ) + raise ex @notify_celery.task( From bcaf53f78daf3ac8714458759c5998a88d2a7bb8 Mon Sep 17 00:00:00 2001 From: Carlo Costino Date: Wed, 30 Jul 2025 11:50:36 -0400 Subject: [PATCH 3/3] Put exception logging in the correct place Signed-off-by: Carlo Costino --- app/celery/scheduled_tasks.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index 9e3bccf8a..709994910 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -282,13 +282,15 @@ def process_delivery_receipts(self): except Exception as ex: retry_count = self.request.retries wait_time = 3600 * 2**retry_count + + current_app.logger.exception(str(ex)) + try: raise self.retry(ex=ex, countdown=wait_time) except self.MaxRetriesExceededError: current_app.logger.error( - f"Failed process delivery receipts after max retries: {str(ex)}" + "Failed process delivery receipts after max retries" ) - raise ex @notify_celery.task(