Shiloh/brotherton-erpnext
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Enqueue Newsletter sending in Longjob Queue

Browse Source
This commit is contained in:
Anand Doshi 2014-08-27 12:23:52 +05:30
parent 54ca95bc6e
commit 46256cddd7
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
erpnext/support/doctype/newsletter/newsletter.py
View File

@ -33,7 +33,9 @@ class Newsletter(Document):
if getattr(frappe.local, "is_ajax", False): if getattr(frappe.local, "is_ajax", False):
# to avoid request timed out! # to avoid request timed out!
self.validate_send() self.validate_send()
erpnext.tasks.send_newsletter.delay(frappe.local.site, self.name)
# hack! event="bulk_long" to queue in longjob queue
erpnext.tasks.send_newsletter.delay(frappe.local.site, self.name, event="bulk_long")
else: else:
self.send_bulk() self.send_bulk()

3
erpnext/tasks.py
View File

@ -6,7 +6,8 @@ import frappe
from frappe.celery_app import celery_task, task_logger from frappe.celery_app import celery_task, task_logger
@celery_task() @celery_task()
def send_newsletter(site, newsletter): def send_newsletter(site, newsletter, event):
# hack! pass event="bulk_long" to queue in longjob queue
try: try:
frappe.connect(site=site) frappe.connect(site=site)
doc = frappe.get_doc("Newsletter", newsletter) doc = frappe.get_doc("Newsletter", newsletter)