Convert RecurringNudge emails to multiple tasks

openedx/core/djangoapps/schedules/management/commands/send_recurring_nudge.py

@@ -2,6 +2,7 @@ from __future__ import print_function
 
 import datetime
 
+from celery import task
 from dateutil.tz import tzutc, gettz
 from django.core.management.base import BaseCommand
 from django.test.utils import CaptureQueriesContext
@@ -33,7 +34,26 @@ class ScheduleStartResolver(RecipientResolver):
         self.target_start_date = target_start_date
 
     def send(self, msg_type):
-        for (user, language, context) in self.build_email_context():
+        schedule_day.delay(self.target_start_date)
+
+    def build_email_context(self):
+
+
+@task
+def schedule_day(target_date):
+    for hour in range(23):
+        schedule_hour.delay(target_date, hour)
+
+
+@task
+def schedule_hour(target_date, hour):
+    for minute in range(60):
+        schedule_minute.delay(target_date, hour, minute)
+
+
+@task
+def schedule_minute(target_date, hour, minute):
+    for (user, language, context) in schedules_for_minute(target_date, hour, minute):
         msg = msg_type.personalize(
             Recipient(
                 user.username,
@@ -42,9 +62,10 @@ class ScheduleStartResolver(RecipientResolver):
             language,
             context
         )
-            ace.send(msg)
+        ace.send.delay(msg)
 
-    def build_email_context(self):
+
+def schedules_for_minute(target_date, hour, minute):
     schedules = Schedule.objects.select_related(
         'enrollment__user__profile',
         'enrollment__course',
@@ -60,19 +81,17 @@ class ScheduleStartResolver(RecipientResolver):
             to_attr='tzprefs'
         ),
     ).filter(
-            start__year=self.target_start_date.year,
-            start__month=self.target_start_date.month,
-            start__day=self.target_start_date.day,
+        start__year=target_date.year,
+        start__month=target_date.month,
+        start__day=target_date.day,
+        start__hour=hour,
+        start__minute=minute,
     )
 
     for schedule in schedules:
         enrollment = schedule.enrollment
         user = enrollment.user
 
-            user_time_zone = tzutc()
-            for preference in user.tzprefs:
-                user_time_zone = gettz(preference.value)
-
         course_id_str = str(enrollment.course_id)
         course = enrollment.course
 

openedx/core/djangoapps/schedules/tasks.py

-from celery import task
-
-
-@task
-def send_email_batch(email_batch):
-    email_batch.send()
-    return 'foo'