diff --git a/erpnext/accounts/doctype/bank_statement_import/bank_statement_import.py b/erpnext/accounts/doctype/bank_statement_import/bank_statement_import.py index 3f5c064f4b..d8880f7041 100644 --- a/erpnext/accounts/doctype/bank_statement_import/bank_statement_import.py +++ b/erpnext/accounts/doctype/bank_statement_import/bank_statement_import.py @@ -53,15 +53,13 @@ class BankStatementImport(DataImport): if "Bank Account" not in json.dumps(preview["columns"]): frappe.throw(_("Please add the Bank Account column")) - from frappe.core.page.background_jobs.background_jobs import get_info + from frappe.utils.background_jobs import is_job_queued from frappe.utils.scheduler import is_scheduler_inactive if is_scheduler_inactive() and not frappe.flags.in_test: frappe.throw(_("Scheduler is inactive. Cannot import data."), title=_("Scheduler Inactive")) - enqueued_jobs = [d.get("job_name") for d in get_info()] - - if self.name not in enqueued_jobs: + if not is_job_queued(self.name): enqueue( start_import, queue="default", diff --git a/erpnext/accounts/doctype/ledger_merge/ledger_merge.py b/erpnext/accounts/doctype/ledger_merge/ledger_merge.py index 18e5a1ac85..7cd6d04c35 100644 --- a/erpnext/accounts/doctype/ledger_merge/ledger_merge.py +++ b/erpnext/accounts/doctype/ledger_merge/ledger_merge.py @@ -4,22 +4,20 @@ import frappe from frappe import _ from frappe.model.document import Document +from frappe.utils.background_jobs import is_job_queued from erpnext.accounts.doctype.account.account import merge_account class LedgerMerge(Document): def start_merge(self): - from frappe.core.page.background_jobs.background_jobs import get_info from frappe.utils.background_jobs import enqueue from frappe.utils.scheduler import is_scheduler_inactive if is_scheduler_inactive() and not frappe.flags.in_test: frappe.throw(_("Scheduler is inactive. Cannot merge accounts."), title=_("Scheduler Inactive")) - enqueued_jobs = [d.get("job_name") for d in get_info()] - - if self.name not in enqueued_jobs: + if not is_job_queued(self.name): enqueue( start_merge, queue="default", diff --git a/erpnext/accounts/doctype/opening_invoice_creation_tool/opening_invoice_creation_tool.py b/erpnext/accounts/doctype/opening_invoice_creation_tool/opening_invoice_creation_tool.py index 99377421c5..f7df1ff4a1 100644 --- a/erpnext/accounts/doctype/opening_invoice_creation_tool/opening_invoice_creation_tool.py +++ b/erpnext/accounts/doctype/opening_invoice_creation_tool/opening_invoice_creation_tool.py @@ -6,7 +6,7 @@ import frappe from frappe import _, scrub from frappe.model.document import Document from frappe.utils import flt, nowdate -from frappe.utils.background_jobs import enqueue +from frappe.utils.background_jobs import enqueue, is_job_queued from erpnext.accounts.doctype.accounting_dimension.accounting_dimension import ( get_accounting_dimensions, @@ -207,14 +207,12 @@ class OpeningInvoiceCreationTool(Document): if len(invoices) < 50: return start_import(invoices) else: - from frappe.core.page.background_jobs.background_jobs import get_info from frappe.utils.scheduler import is_scheduler_inactive if is_scheduler_inactive() and not frappe.flags.in_test: frappe.throw(_("Scheduler is inactive. Cannot import data."), title=_("Scheduler Inactive")) - enqueued_jobs = [d.get("job_name") for d in get_info()] - if self.name not in enqueued_jobs: + if not is_job_queued(self.name): enqueue( start_import, queue="default", diff --git a/erpnext/accounts/doctype/pos_invoice_merge_log/pos_invoice_merge_log.py b/erpnext/accounts/doctype/pos_invoice_merge_log/pos_invoice_merge_log.py index 81a234a20a..a0a1c8c269 100644 --- a/erpnext/accounts/doctype/pos_invoice_merge_log/pos_invoice_merge_log.py +++ b/erpnext/accounts/doctype/pos_invoice_merge_log/pos_invoice_merge_log.py @@ -6,11 +6,10 @@ import json import frappe from frappe import _ -from frappe.core.page.background_jobs.background_jobs import get_info from frappe.model.document import Document from frappe.model.mapper import map_child_doc, map_doc from frappe.utils import cint, flt, get_time, getdate, nowdate, nowtime -from frappe.utils.background_jobs import enqueue +from frappe.utils.background_jobs import enqueue, is_job_queued from frappe.utils.scheduler import is_scheduler_inactive @@ -467,7 +466,7 @@ def enqueue_job(job, **kwargs): closing_entry = kwargs.get("closing_entry") or {} job_name = closing_entry.get("name") - if not job_already_enqueued(job_name): + if not is_job_queued(job_name): enqueue( job, **kwargs, @@ -491,12 +490,6 @@ def check_scheduler_status(): frappe.throw(_("Scheduler is inactive. Cannot enqueue job."), title=_("Scheduler Inactive")) -def job_already_enqueued(job_name): - enqueued_jobs = [d.get("job_name") for d in get_info()] - if job_name in enqueued_jobs: - return True - - def safe_load_json(message): try: json_message = json.loads(message).get("message")