vassili/seitime-frappe
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

fix: Skip cleanup while fetching RQ job (#32046)

Browse source
This commit is contained in:
Ankush Menat 2025-04-09 20:41:59 +05:30 • committed by GitHub
parent ee9af7f3ae
commit 100f66b7ba
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
frappe/core/doctype/rq_job/rq_job.py
View file

@ -199,7 +199,10 @@ def fetch_job_ids(queue: Queue, status: str) -> list[str]:
registry = registry_map.get(status)
if registry is not None:
job_ids = registry.get_job_ids()
if isinstance(registry, Queue):
job_ids = registry.get_job_ids()
else:
job_ids = registry.get_job_ids(cleanup=False)
return [j for j in job_ids if j]
return []
@ -210,7 +213,7 @@ def remove_failed_jobs():
frappe.only_for("System Manager")
for queue in get_queues():
fail_registry = queue.failed_job_registry
failed_jobs = filter_current_site_jobs(fail_registry.get_job_ids())
failed_jobs = filter_current_site_jobs(fail_registry.get_job_ids(cleanup=False))
# Delete in batches to avoid loading too many things in memory
conn = get_redis_conn()