1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
from django.conf import settings
from django.core.mail.backends.base import BaseEmailBackend
from djcelery_email.tasks import send_emails
from djcelery_email.utils import chunked, email_to_dict
class CeleryEmailBackend(BaseEmailBackend):
def __init__(self, fail_silently=False, **kwargs):
super(CeleryEmailBackend, self).__init__(fail_silently)
self.init_kwargs = kwargs
def send_messages(self, email_messages):
result_tasks = []
for chunk in chunked(email_messages, settings.CELERY_EMAIL_CHUNK_SIZE):
chunk_messages = [email_to_dict(msg) for msg in chunk]
result_tasks.append(send_emails.delay(chunk_messages, self.init_kwargs))
return result_tasks
|
