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

refactor: barebones retry functionality

Browse Source 
(cherry picked from commit 0aa1636d04bed9fef260aedde4ed6a42b6a1968b)
This commit is contained in:
ruthra kumar 2023-11-10 12:20:30 +05:30 committed by Mergify
parent 33f1e709f1
commit db60e147e0
2 changed files with 36 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
erpnext/bulk_transaction/doctype/bulk_transaction_log/bulk_transaction_log.js
View File

@ -9,5 +9,13 @@ frappe.ui.form.on("Bulk Transaction Log", {
frm.add_custom_button(__('Failed Entries'), function() {
frappe.set_route('List', 'Bulk Transaction Log Detail', {'date': frm.doc.date, 'transaction_status': "Failed"});
}, __("View"));
if (frm.doc.failed) {
frm.add_custom_button(__('Retry Failed Transactions'), function() {
frappe.call({
method: "erpnext.utilities.bulk_transaction.retry_failed_transactions",
args: {date: frm.doc.date}
}).then(()=> { });
});
}
},
});

28
erpnext/utilities/bulk_transaction.py
View File

@ -29,6 +29,34 @@ def transaction_processing(data, from_doctype, to_doctype):
job(deserialized_data, from_doctype, to_doctype)
@frappe.whitelist()
def retry_failed_transactions(date: str | None):
if date:
failed_docs = frappe.db.get_all(
"Bulk Transaction Log Detail",
filters={"date": date, "transaction_status": "Failed", "retried": 0},
fields=["name", "transaction_name", "from_doctype", "to_doctype"],
)
if not failed_docs:
frappe.msgprint("There are no Failed transactions")
return
for log in failed_docs:
try:
frappe.db.savepoint("before_creation_state")
task(log.transaction_name, log.from_doctype, log.to_doctype)
except Exception as e:
frappe.db.rollback(save_point="before_creation_state")
update_log(log.name, "Failed", 1)
else:
update_log(log.name, "Success", 1)
def update_log(log_name, status, retried):
frappe.db.set_value("Bulk Transaction Log Detail", log_name, "transaction_status", status)
frappe.db.set_value("Bulk Transaction Log Detail", log_name, "retried", retried)
def job(deserialized_data, from_doctype, to_doctype):
fail_count = 0
for d in deserialized_data: