diff --git a/api/app/tasks/worker_registry_tasks.py b/api/app/tasks/worker_registry_tasks.py index 865689c..f514ce9 100644 --- a/api/app/tasks/worker_registry_tasks.py +++ b/api/app/tasks/worker_registry_tasks.py @@ -5,7 +5,11 @@ from ..core.config import get_settings from ..services.worker_registry_service import sweep_offline_workers -@celery_app.task(name="app.tasks.worker_registry_tasks.sweep_worker_registry_offline") +@celery_app.task( + name="app.tasks.worker_registry_tasks.sweep_worker_registry_offline", + ignore_result=True, + track_started=False, +) def sweep_worker_registry_offline() -> dict[str, int]: settings = get_settings() updated_count = sweep_offline_workers(ttl_seconds=settings.worker_registry_ttl_seconds) diff --git a/web/src/app/admin/task-monitor/page.tsx b/web/src/app/admin/task-monitor/page.tsx index 215f56b..990415b 100644 --- a/web/src/app/admin/task-monitor/page.tsx +++ b/web/src/app/admin/task-monitor/page.tsx @@ -357,7 +357,7 @@ export default function AdminTaskMonitorPage() { rows.push(...toTaskRows(overview.worker, "SCHEDULED", overview.scheduled_tasks)); rows.push(...toTaskRows(overview.worker, "RECENT", overview.recent_tasks)); } - return rows; + return rows.filter((task) => task.name !== "app.tasks.worker_registry_tasks.sweep_worker_registry_offline"); }, [allTasksQuery.data]); const filteredTaskRows = useMemo(() => {