brotherton-erpnext/erpnext/tasks.py
2014-07-22 19:49:16 +05:30

30 lines
599 B
Python

# Copyright (c) 2013, Web Notes Technologies Pvt. Ltd. and Contributors
# MIT License. See license.txt
from __future__ import unicode_literals
import frappe
from frappe.celery_app import celery_task, task_logger
@celery_task()
def send_newsletter(site, newsletter):
try:
frappe.connect(site=site)
doc = frappe.get_doc("Newsletter", newsletter)
doc.send_bulk()
except:
frappe.db.rollback()
task_logger.warn(frappe.get_traceback())
# wasn't able to send emails :(
doc.db_set("email_sent", 0)
frappe.db.commit()
raise
else:
frappe.db.commit()
finally:
frappe.destroy()