From 55de855b324b7b6ce194ad49dd6323627cc07db8 Mon Sep 17 00:00:00 2001 From: Shrihari Mahabal Date: Wed, 4 Mar 2026 17:44:09 +0530 Subject: [PATCH] fix: correct add_to_date function call and parameterize batch size in get_queue sql query --- frappe/email/queue.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/frappe/email/queue.py b/frappe/email/queue.py index 67a13479f6..e0aa112e60 100755 --- a/frappe/email/queue.py +++ b/frappe/email/queue.py @@ -163,10 +163,10 @@ def flush(): def get_queue(): batch_size = cint(frappe.conf.email_queue_batch_size) or 500 - undo_window = add_to_date(now_datetime(seconds=-10)) + undo_window = add_to_date(now_datetime(), seconds=-10) return frappe.db.sql( - f"""select + """select name, sender from `tabEmail Queue` @@ -176,8 +176,8 @@ def get_queue(): (creation < %(undo_window)s) order by priority desc, retry asc, creation asc - limit {batch_size}""", - {"now": now_datetime(), "undo_window": undo_window}, + limit %(batch_size)s""", + {"now": now_datetime(), "undo_window": undo_window, "batch_size": batch_size}, as_dict=True, )