sartography/uva-covid19-testing-communicator
1
0
Fork 0
mirror of https://github.com/sartography/uva-covid19-testing-communicator.git synced 2025-02-23 12:28:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Limit to 190 at a time, and then set interval to be 5 minutes and pray for the best.

Browse Source
This commit is contained in:
Dan 2020-11-13 14:08:32 -05:00
parent bb114adf65
commit 1328979bd3
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
communicator/api/admin.py
View File

@ -84,16 +84,18 @@ def _notify_by_email(file_name=None, retry=False):
continue
try:
notifier.send_result_email(sample)
count += 1
sample.email_notified = True
db.session.add(Notification(type=EMAIL_TYPE, sample=sample, successful=True))
except Exception as e:
db.session.add(Notification(type=EMAIL_TYPE, sample=sample, successful=False,
error_message=str(e)))
count += 1
db.session.commit()
sleep(0.5)
if count % 100 == 0:
sleep(300) # Sleep for 5 minutes after every 100 records to avoid throttling errors.
if count > 190:
break
def notify_by_text(file_name=None, retry=False):
executor.submit(_notify_by_text, file_name, retry)
@ -116,21 +118,21 @@ def _notify_by_text(file_name=None, retry=False):
# Do not limit texts, as errors pile up we end up sending less and less, till none go out.
# sample_query = sample_query.limit(150) # Only send out 150 texts at a time.
count = 0
samples = sample_query.all()
count = 0
for sample in samples:
last_failure = sample.last_failure_by_type(TEXT_TYPE)
if last_failure and not retry:
continue
try:
notifier.send_result_sms(sample)
count += 1
sample.text_notified = True
db.session.add(Notification(type=TEXT_TYPE, sample=sample, successful=True))
except Exception as e:
db.session.add(Notification(type=TEXT_TYPE, sample=sample, successful=False,
error_message=str(e)))
count += 1
db.session.commit()
sleep(0.5)
if count % 100 == 0:
sleep(300) # Sleep for 5 minutes after every 100 records to avoid throttling errors.
if count > 190:
break