darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-13 14:42:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

More fixes.

Browse Source 
Signed-off-by: Cliff Hill <Clifford.hill@gsa.gov>
This commit is contained in:
Cliff Hill
2024-11-22 16:35:56 -05:00
parent 5aa16bf4cc
commit 054bd2d7f1
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
app/celery/tasks.py
View File

@@ -358,13 +358,14 @@ def _save_api_task_handler(func):
current_app.logger.exception(
f"Max retry failed Failed to persist notification {notification['id']}",
)
raise
return save_api_task_wrapper
@_save_api_task_handler
@notify_celery.task(
bind=True, name="save-api-email", max_retries=5, default_retry_delay=300
bind=True, name="save-api-email", max_retries=5, default_retry_delay=300, autoretry_for=SQLAlchemyError,
)
def save_api_email(self, encrypted_notification):
save_api_email_or_sms(self, encrypted_notification)
@@ -372,7 +373,7 @@ def save_api_email(self, encrypted_notification):
@_save_api_task_handler
@notify_celery.task(
bind=True, name="save-api-sms", max_retries=5, default_retry_delay=300
bind=True, name="save-api-sms", max_retries=5, default_retry_delay=300, autoretry_for=SQLAlchemyError,
)
def save_api_sms(self, encrypted_notification):
save_api_email_or_sms(self, encrypted_notification)
@@ -440,7 +441,7 @@ def _send_inbound_sms_to_service_handler(func):
@_send_inbound_sms_to_service_handler
@notify_celery.task(
bind=True, name="send-inbound-sms", max_retries=5, default_retry_delay=300
bind=True, name="send-inbound-sms", max_retries=5, default_retry_delay=300, autoretry_for=RequestException,
)
def send_inbound_sms_to_service(self, inbound_sms_id, service_id):
inbound_api = get_service_inbound_api_for_service(service_id=service_id)