From fede173a3e05b0f23bda88f6cf3c41b8537b3e71 Mon Sep 17 00:00:00 2001 From: Kenneth Kehl <@kkehl@flexion.us> Date: Tue, 10 Dec 2024 10:39:26 -0800 Subject: [PATCH 1/2] change worker_max_tasks_per_child to 2000 --- app/config.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/config.py b/app/config.py index 12159e289..1ec8abd59 100644 --- a/app/config.py +++ b/app/config.py @@ -167,7 +167,7 @@ class Config(object): current_minute = (datetime.now().minute + 1) % 60 CELERY = { - "worker_max_tasks_per_child": 500, + "worker_max_tasks_per_child": 2000, "broker_url": REDIS_URL, "broker_transport_options": { "visibility_timeout": 310, From bdb73e9db29997cf3c14a487fbb8149b39ddb1da Mon Sep 17 00:00:00 2001 From: Kenneth Kehl <@kkehl@flexion.us> Date: Tue, 10 Dec 2024 12:26:46 -0800 Subject: [PATCH 2/2] fix time limit in checking delivery receipts --- app/clients/cloudwatch/aws_cloudwatch.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/clients/cloudwatch/aws_cloudwatch.py b/app/clients/cloudwatch/aws_cloudwatch.py index 36bcf5dca..8ef34abac 100644 --- a/app/clients/cloudwatch/aws_cloudwatch.py +++ b/app/clients/cloudwatch/aws_cloudwatch.py @@ -158,7 +158,7 @@ def check_sms(self, message_id, notification_id, created_at): message["delivery"].get("phoneCarrier", "Unknown Carrier"), ) - if time_now > (created_at + timedelta(hours=3)): + if time_now > (created_at + timedelta(hours=73)): # see app/models.py Notification. This message corresponds to "permanent-failure", # but we are copy/pasting here to avoid circular imports. return "failure", "Unable to find carrier response."