stale/django-queued-mailer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix argument pass to task

Browse Source
This commit is contained in:
jar3b 2018-12-05 16:54:46 +03:00
parent 3b42bb9af3
commit b50d6c06ea
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
queued_mailer/backend.py
View File

@ -24,7 +24,7 @@ class EmailBackend(BaseEmailBackend):
num_sent = 0 num_sent = 0
for email in email_messages: for email in email_messages:
try: try:
self.task.apply_async(email) self.task.apply_async([email,])
num_sent += 1 num_sent += 1
except Exception as e: except Exception as e:
logger.error("cannot send message %s: %r" % (_get_message_recipients(email), e)) logger.error("cannot send message %s: %r" % (_get_message_recipients(email), e))

4
queued_mailer/tasks.py
View File

@ -3,6 +3,6 @@ from .settings import EMAIL_BACKEND
@app.task() @app.task()
def send_message(): def send_message(email):
logger.info(EMAIL_BACKEND) logger.info(EMAIL_BACKEND)
logger.info('sent') logger.info(email)