darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-08-23 07:46:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix cronitor

Browse Source
This commit is contained in:
Kenneth Kehl
2025-07-10 09:43:32 -07:00
parent c0a97985d7
commit 2bfcd4a54d
2 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/celery/nightly_tasks.py
View File

@@ -8,7 +8,6 @@ from app.aws import s3
from app.aws.s3 import remove_csv_object from app.aws.s3 import remove_csv_object
from app.celery.process_ses_receipts_tasks import check_and_queue_callback_task from app.celery.process_ses_receipts_tasks import check_and_queue_callback_task
from app.config import QueueNames from app.config import QueueNames
from app.cronitor import cronitor
from app.dao.fact_processing_time_dao import insert_update_processing_time from app.dao.fact_processing_time_dao import insert_update_processing_time
from app.dao.inbound_sms_dao import delete_inbound_sms_older_than_retention from app.dao.inbound_sms_dao import delete_inbound_sms_older_than_retention
from app.dao.jobs_dao import ( from app.dao.jobs_dao import (
@@ -31,7 +30,6 @@ from app.utils import get_midnight_in_utc, utc_now
@notify_celery.task(name="remove-sms-email-jobs") @notify_celery.task(name="remove-sms-email-jobs")
@cronitor("remove-sms-email-jobs")
def remove_sms_email_csv_files(): def remove_sms_email_csv_files():
_remove_csv_files([NotificationType.EMAIL, NotificationType.SMS]) _remove_csv_files([NotificationType.EMAIL, NotificationType.SMS])
@@ -76,13 +74,13 @@ def delete_notifications_older_than_retention():
@notify_celery.task(name="delete-sms-notifications") @notify_celery.task(name="delete-sms-notifications")
@cronitor("delete-sms-notifications") # @cronitor("delete-sms-notifications")
def delete_sms_notifications_older_than_retention(): def delete_sms_notifications_older_than_retention():
_delete_notifications_older_than_retention_by_type(NotificationType.SMS) _delete_notifications_older_than_retention_by_type(NotificationType.SMS)
@notify_celery.task(name="delete-email-notifications") @notify_celery.task(name="delete-email-notifications")
@cronitor("delete-email-notifications") # @cronitor("delete-email-notifications")
def delete_email_notifications_older_than_retention(): def delete_email_notifications_older_than_retention():
_delete_notifications_older_than_retention_by_type(NotificationType.EMAIL) _delete_notifications_older_than_retention_by_type(NotificationType.EMAIL)
@@ -162,7 +160,6 @@ def delete_notifications_for_service_and_type(
@notify_celery.task(name="timeout-sending-notifications") @notify_celery.task(name="timeout-sending-notifications")
@cronitor("timeout-sending-notifications")
def timeout_notifications(): def timeout_notifications():
notifications = ["dummy value so len() > 0"] notifications = ["dummy value so len() > 0"]
@@ -184,7 +181,6 @@ def timeout_notifications():
@notify_celery.task(name="delete-inbound-sms") @notify_celery.task(name="delete-inbound-sms")
@cronitor("delete-inbound-sms")
def delete_inbound_sms(): def delete_inbound_sms():
try: try:
start = utc_now() start = utc_now()
@@ -200,7 +196,6 @@ def delete_inbound_sms():
@notify_celery.task(name="save-daily-notification-processing-time") @notify_celery.task(name="save-daily-notification-processing-time")
@cronitor("save-daily-notification-processing-time")
def save_daily_notification_processing_time(local_date=None): def save_daily_notification_processing_time(local_date=None):
# local_date is a string in the format of "YYYY-MM-DD" # local_date is a string in the format of "YYYY-MM-DD"
if local_date is None: if local_date is None:

10
app/config.py
View File

@@ -316,6 +316,16 @@ class Config(object):
"schedule": crontab(hour=8, minute=0), "schedule": crontab(hour=8, minute=0),
"options": {"queue": QueueNames.PERIODIC}, "options": {"queue": QueueNames.PERIODIC},
}, },
"delete-sms-notifications": {
"task": "delete-sms-notifications",
"schedule": crontab(hour=8, minute=46),
"options": {"queue": QueueNames.PERIODIC},
},
"delete-email-notifications": {
"task": "delete-sms-notifications",
"schedule": crontab(hour=8, minute=17),
"options": {"queue": QueueNames.PERIODIC},
},
"check-for-services-with-high-failure-rates-or-sending-to-tv-numbers": { "check-for-services-with-high-failure-rates-or-sending-to-tv-numbers": {
"task": "check-for-services-with-high-failure-rates-or-sending-to-tv-numbers", "task": "check-for-services-with-high-failure-rates-or-sending-to-tv-numbers",
"schedule": crontab(day_of_week="mon-fri", hour=14, minute=30), "schedule": crontab(day_of_week="mon-fri", hour=14, minute=30),