mirror of
https://github.com/frappe/erpnext.git
synced 2026-05-27 17:04:47 +00:00
refactor: atomic summarization step for process pcv
(cherry picked from commit 6cb7971342)
This commit is contained in:
@@ -289,15 +289,22 @@ def schedule_next_date(docname: str):
|
|||||||
)
|
)
|
||||||
# Ensure both normal and opening balances are processed for all dates
|
# Ensure both normal and opening balances are processed for all dates
|
||||||
if total_no_of_dates == completed:
|
if total_no_of_dates == completed:
|
||||||
frappe.enqueue(
|
from erpnext.accounts.doctype.process_payment_reconciliation.process_payment_reconciliation import (
|
||||||
method="erpnext.accounts.doctype.process_period_closing_voucher.process_period_closing_voucher.summarize_and_post_ledger_entries",
|
is_job_running,
|
||||||
queue="long",
|
|
||||||
timeout="3600",
|
|
||||||
is_async=True,
|
|
||||||
enqueue_after_commit=True,
|
|
||||||
docname=docname,
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
job_name = f"summarize_{docname}"
|
||||||
|
if not is_job_running(job_name):
|
||||||
|
frappe.enqueue(
|
||||||
|
method="erpnext.accounts.doctype.process_period_closing_voucher.process_period_closing_voucher.summarize_and_post_ledger_entries",
|
||||||
|
queue="long",
|
||||||
|
timeout="3600",
|
||||||
|
is_async=True,
|
||||||
|
job_name=job_name,
|
||||||
|
enqueue_after_commit=True,
|
||||||
|
docname=docname,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
def make_dict_json_compliant(dimension_wise_balance) -> dict:
|
def make_dict_json_compliant(dimension_wise_balance) -> dict:
|
||||||
"""
|
"""
|
||||||
|
|||||||
Reference in New Issue
Block a user