Commit 352fa067 by Calen Pennington

Induce a base class for the scheduling tasks

parent 0c5d788a
......@@ -65,10 +65,11 @@ def _recurring_nudge_schedule_send(site_id, msg_str):
ace.send(msg)
class ScheduleRecurringNudge(Task):
ignore_result=True
routing_key=ROUTING_KEY
class ScheduleMessageBaseTask(Task):
ignore_result = True
routing_key = ROUTING_KEY
class ScheduleRecurringNudge(ScheduleMessageBaseTask):
def run(
self, site_id, target_day_str, day_offset, bin_num, org_list, exclude_orgs=False, override_recipient_email=None,
):
......@@ -84,10 +85,7 @@ class ScheduleRecurringNudge(Task):
)
class ScheduleUpgradeReminder(Task):
ignore_result=True
routing_key=ROUTING_KEY
class ScheduleUpgradeReminder(ScheduleMessageBaseTask):
def run(
self, site_id, target_day_str, day_offset, bin_num, org_list, exclude_orgs=False, override_recipient_email=None,
):
......@@ -112,10 +110,7 @@ def _upgrade_reminder_schedule_send(site_id, msg_str):
ace.send(msg)
class ScheduleCourseUpdate(Task):
ignore_result=True
routing_key=ROUTING_KEY
class ScheduleCourseUpdate(ScheduleMessageBaseTask):
def run(
self, site_id, target_day_str, day_offset, bin_num, org_list, exclude_orgs=False, override_recipient_email=None,
):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment