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

introduce gaps in message sends

Browse Source
This commit is contained in:
Kenneth Kehl
2024-12-20 09:58:03 -08:00
parent 786b6610e3
commit 1bac8a82a0
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
app/celery/tasks.py
View File

@@ -1,4 +1,5 @@
import json import json
from time import sleep
from celery.signals import task_postrun from celery.signals import task_postrun
from flask import current_app from flask import current_app
@@ -75,8 +76,15 @@ def process_job(job_id, sender_id=None):
) )
) )
# notify-api-1495 we are going to sleep periodically to give other
# jobs running at the same time a chance to get some of their messages
# sent. Sleep for 5 minutes after every 500 sends
count = 0
for row in recipient_csv.get_rows(): for row in recipient_csv.get_rows():
process_row(row, template, job, service, sender_id=sender_id) process_row(row, template, job, service, sender_id=sender_id)
count = count + 1
if count % 500 == 0:
sleep(5 * 60)
# End point/Exit point for message send flow. # End point/Exit point for message send flow.
job_complete(job, start=start) job_complete(job, start=start)