Merge pull request #21770 from resilient-tech/perf-scheduler

This commit is contained in:
Sagar Vora 2023-07-23 10:08:13 +00:00 committed by GitHub
commit 9571bc1e99
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -83,9 +83,9 @@ def enqueue_events_for_site(site: str) -> None:
def enqueue_events(site: str) -> list[str] | None: def enqueue_events(site: str) -> list[str] | None:
if schedule_jobs_based_on_activity(): if schedule_jobs_based_on_activity():
enqueued_jobs = [] enqueued_jobs = []
for job_type in frappe.get_all("Scheduled Job Type", ("name", "method"), {"stopped": 0}): for job_type in frappe.get_all("Scheduled Job Type", filters={"stopped": 0}, fields="*"):
job_type = frappe.get_cached_doc("Scheduled Job Type", job_type.name) job_type = frappe.get_doc(doctype="Scheduled Job Type", **job_type)
if _enqueued := job_type.enqueue(): if job_type.enqueue():
enqueued_jobs.append(job_type.method) enqueued_jobs.append(job_type.method)
return enqueued_jobs return enqueued_jobs