fix: Lock email queue before sending (#35334)

Avoids duplicate flushes.
This commit is contained in:
Ankush Menat 2025-12-18 16:06:24 +05:30 committed by GitHub
parent 8cf4af84f4
commit c944981a3e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -147,7 +147,7 @@ def flush():
failed_email_queues = []
for row in email_queue_batch:
try:
email_queue: EmailQueue = frappe.get_doc("Email Queue", row.name)
email_queue: EmailQueue = frappe.get_doc("Email Queue", row.name, for_update=True)
email_queue.send()
except Exception:
frappe.get_doc("Email Queue", row.name).log_error()