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, }