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

fix: run scheduler for reposting if there is no scheduler is running for the reposting

Browse Source
This commit is contained in:
Rohit Waghchaure 2021-05-16 16:48:44 +05:30
parent e9f6c8cdb1
commit 0517abad43
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
erpnext/stock/doctype/repost_item_valuation/repost_item_valuation.py
View File

@ -4,8 +4,9 @@
from __future__ import unicode_literals from __future__ import unicode_literals
import frappe, erpnext import frappe, erpnext
from rq.timeouts import JobTimeoutException
from frappe.model.document import Document from frappe.model.document import Document
from frappe.utils import cint, get_link_to_form, add_to_date, now, today from frappe.utils import cint, get_link_to_form, add_to_date, now, today, time_diff_in_hours
from erpnext.stock.stock_ledger import repost_future_sle from erpnext.stock.stock_ledger import repost_future_sle
from erpnext.accounts.utils import update_gl_entries_after, check_if_stock_and_account_balance_synced from erpnext.accounts.utils import update_gl_entries_after, check_if_stock_and_account_balance_synced
from frappe.utils.user import get_users_with_role from frappe.utils.user import get_users_with_role
@ -57,7 +58,8 @@ def repost(doc):
repost_gl_entries(doc) repost_gl_entries(doc)
doc.set_status('Completed') doc.set_status('Completed')
except Exception:
except (Exception, JobTimeoutException):
frappe.db.rollback() frappe.db.rollback()
traceback = frappe.get_traceback() traceback = frappe.get_traceback()
frappe.log_error(traceback) frappe.log_error(traceback)
@ -113,6 +115,12 @@ def notify_error_to_stock_managers(doc, traceback):
frappe.sendmail(recipients=recipients, subject=subject, message=message) frappe.sendmail(recipients=recipients, subject=subject, message=message)
def repost_entries(): def repost_entries():
job_log = frappe.get_all('Scheduled Job Log', fields = ['status', 'creation'],
filters = {'scheduled_job_type': 'repost_item_valuation.repost_entries'}, order_by='creation desc', limit=1)
if job_log and job_log[0]['status'] == 'Start' and time_diff_in_hours(now(), job_log[0]['creation']) < 2:
return
riv_entries = get_repost_item_valuation_entries() riv_entries = get_repost_item_valuation_entries()
for row in riv_entries: for row in riv_entries: