From d7c355371445ef56258ab77d9cc87c4adb8b4235 Mon Sep 17 00:00:00 2001 From: Akhil Narang Date: Wed, 29 Jan 2025 17:38:23 +0530 Subject: [PATCH] chore: refactor for rq 2.x There's no `Connection` anymore - we need to explicitly pass it in everywhere Signed-off-by: Akhil Narang --- frappe/utils/doctor.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/frappe/utils/doctor.py b/frappe/utils/doctor.py index 51dd7335c3..cef992537e 100644 --- a/frappe/utils/doctor.py +++ b/frappe/utils/doctor.py @@ -1,6 +1,6 @@ from collections import defaultdict -from rq import Connection, Worker +from rq import Worker import frappe.utils from frappe.utils.background_jobs import get_queue, get_queue_list, get_redis_conn @@ -8,8 +8,7 @@ from frappe.utils.scheduler import is_scheduler_disabled, is_scheduler_inactive def get_workers(): - with Connection(get_redis_conn()): - return Worker.all() + return Worker.all(connection=get_redis_conn()) def purge_pending_jobs(event=None, site=None, queue=None):