diff --git a/openedx/core/djangoapps/schedules/resolvers.py b/openedx/core/djangoapps/schedules/resolvers.py index 440b558ca5..4dc8763d2e 100644 --- a/openedx/core/djangoapps/schedules/resolvers.py +++ b/openedx/core/djangoapps/schedules/resolvers.py @@ -168,7 +168,7 @@ class ScheduleStartResolver(BinnedSchedulesBaseResolver): """ log_prefix = 'Scheduled Nudge' - def schedule_bin(self, msg_type): + def send(self, msg_type): _annotate_for_monitoring(msg_type, self.site, self.bin_num, self.target_datetime, self.day_offset) for (user, language, context) in self.schedules_for_bin(): @@ -239,7 +239,7 @@ class UpgradeReminderResolver(BinnedSchedulesBaseResolver): """ log_prefix = 'Upgrade Reminder' - def schedule_bin(self, msg_type): + def send(self, msg_type): _annotate_for_monitoring(msg_type, self.site, self.bin_num, self.target_datetime, self.day_offset) for (user, language, context) in self.schedules_for_bin(): @@ -335,7 +335,7 @@ class CourseUpdateResolver(BinnedSchedulesBaseResolver): """ log_prefix = 'Course Update' - def schedule_bin(self, msg_type): + def send(self, msg_type): _annotate_for_monitoring(msg_type, self.site, self.bin_num, self.target_datetime, self.day_offset) for (user, language, context) in self._course_update_schedules_for_bin(): diff --git a/openedx/core/djangoapps/schedules/tasks.py b/openedx/core/djangoapps/schedules/tasks.py index f51b961247..627ad23c06 100644 --- a/openedx/core/djangoapps/schedules/tasks.py +++ b/openedx/core/djangoapps/schedules/tasks.py @@ -144,7 +144,7 @@ class ScheduleMessageBaseTask(Task): org_list, exclude_orgs=exclude_orgs, override_recipient_email=override_recipient_email, - ).schedule_bin(msg_type) + ).send(msg_type) def make_message_type(self, day_offset): raise NotImplementedError()