From 352fa067aeb788f3617e31ee80fb4955a3b49dbc Mon Sep 17 00:00:00 2001 From: Calen Pennington Date: Wed, 18 Oct 2017 10:22:06 -0400 Subject: [PATCH] Induce a base class for the scheduling tasks --- openedx/core/djangoapps/schedules/tasks.py | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) diff --git a/openedx/core/djangoapps/schedules/tasks.py b/openedx/core/djangoapps/schedules/tasks.py index a13bd5cfe1..0fd135aa24 100644 --- a/openedx/core/djangoapps/schedules/tasks.py +++ b/openedx/core/djangoapps/schedules/tasks.py @@ -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, ):