sander/rowsandall
Private
Public Access
1
0
Fork 0
Code Activity

email as remote task

Browse Source
This commit is contained in:
Sander Roosendaal
2019-08-19 16:34:01 +02:00
parent 52dff568a2
commit 270feb4dde
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
rowers/management/commands/processalerts.py
View File

@@ -11,6 +11,9 @@ from rowers.tasks import handle_send_email_alert
from rowers import alerts from rowers import alerts
from rowers.utils import myqueue
import django_rq import django_rq
queue = django_rq.get_queue('default') queue = django_rq.get_queue('default')
queuelow = django_rq.get_queue('low') queuelow = django_rq.get_queue('low')
@@ -35,20 +38,21 @@ class Command(BaseCommand):
else: else:
testing = False testing = False
todaysalerts = Alert.objects.filter(next_run = datetime.date.today(),emailalert=True) todaysalerts = Alert.objects.filter(next_run <= datetime.date.today(),emailalert=True)
for alert in todaysalerts: for alert in todaysalerts:
stats = alerts.alert_get_stats(alert) stats = alerts.alert_get_stats(alert)
# send email # send email
handle_send_email_alert(alert.manager.email, job = myqueue(queue,handle_send_email_alert,
alert.manager.first_name, alert.manager.email,
alert.manager.last_name, alert.manager.first_name,
stats,debug=True) alert.manager.last_name,
stats,debug=True)
# advance next_run # advance next_run
if not testing: if not testing:
alert.next_run = alert.next_run + datetime.timedelta(days=alert.period) alert.next_run = datetime.date.today() + datetime.timedelta(days=alert.period)
alert.save() alert.save()
if testing: if testing: