diff --git a/app/celery/process_pinpoint_receipts_tasks.py b/app/celery/process_pinpoint_receipts_tasks.py index 21410bdcc8..ca0cc92cd5 100644 --- a/app/celery/process_pinpoint_receipts_tasks.py +++ b/app/celery/process_pinpoint_receipts_tasks.py @@ -114,6 +114,8 @@ def process_pinpoint_results(self, response): current_app.logger.exception(f"Error processing Pinpoint results: {str(e)}") self.retry(queue=QueueNames.RETRY) + return True + def determine_pinpoint_status(sns_status, provider_response): if sns_status == "DELIVERED":