From 077707f493debba6ab415f05753a9871c5bcd515 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Fri, 15 Mar 2024 16:41:13 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20celeryinfo=E5=8F=96=E5=80=BC=E9=94=99?= =?UTF-8?q?=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/monitor/services.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/apps/monitor/services.py b/apps/monitor/services.py index 71676546..78a0ec86 100644 --- a/apps/monitor/services.py +++ b/apps/monitor/services.py @@ -108,18 +108,23 @@ class CeleryMonitor: def get_info(cls): count_active_task = 0 count_scheduled_task = 0 + count_registered_task = 0 active_tasks = celery_inspect.active() if active_tasks: _, first_value = active_tasks.popitem() count_active_task = len(first_value) scheduled_tasks = celery_inspect.scheduled() if scheduled_tasks: - _, first_value = active_tasks.popitem() + _, first_value = scheduled_tasks.popitem() count_scheduled_task = len(first_value) - print(active_tasks) + registered_tasks = celery_inspect.registered() + if registered_tasks: + _, first_value = registered_tasks.popitem() + count_registered_task = len(first_value) return { 'count_active_task': count_active_task, 'count_scheduled_task': count_scheduled_task, + 'count_registered_task': count_registered_task, }