dashboard: fix send_email_notifications task

circle/dashboard/tasks/local_periodic_tasks.py

@@ -41,6 +41,7 @@ def send_email_notifications():
     for i in Notification.objects.filter(q):
     for i in Notification.objects.filter(q):
         recipients.setdefault(i.to, [])
         recipients.setdefault(i.to, [])
         recipients[i.to].append(i)
         recipients[i.to].append(i)
+    logger.info("Delivering notifications to %d users", len(recipients))
 
 
     for user, msgs in recipients.iteritems():
     for user, msgs in recipients.iteritems():
         if (not user.profile or not user.email or not
         if (not user.profile or not user.email or not

circle/manager/mancelery.py

@@ -32,6 +32,7 @@ celery = Celery('manager',
                          'storage.tasks.periodic_tasks',
                          'storage.tasks.periodic_tasks',
                          'firewall.tasks.local_tasks',
                          'firewall.tasks.local_tasks',
                          'monitor.tasks.local_periodic_tasks',
                          'monitor.tasks.local_periodic_tasks',
+                         'dashboard.tasks.local_periodic_tasks',
                          ])
                          ])
 
 
 celery.conf.update(
 celery.conf.update(
@@ -60,7 +61,7 @@ celery.conf.update(
             'schedule': timedelta(hours=1),
             'schedule': timedelta(hours=1),
             'options': {'queue': 'localhost.man'}
             'options': {'queue': 'localhost.man'}
         },
         },
-        'dashboard.local_periodic_tasks': {
+        'dashboard.send_email_notifications': {
             'task': 'dashboard.tasks.local_periodic_tasks.'
             'task': 'dashboard.tasks.local_periodic_tasks.'
             'send_email_notifications',
             'send_email_notifications',
             'schedule': timedelta(hours=24),
             'schedule': timedelta(hours=24),