From f866ee3fa8d00cded7b8e922adf7cf6375b0ecb4 Mon Sep 17 00:00:00 2001 From: chengkai3 Date: Sun, 28 Jun 2026 09:54:03 +0800 Subject: [PATCH] =?UTF-8?q?fix:[FL-203][=E8=B0=83=E5=BA=A6=E7=9B=91?= =?UTF-8?q?=E6=8E=A7=E9=A1=B5=E9=9D=A2=E6=89=A7=E8=A1=8C=E8=8A=82=E7=82=B9?= =?UTF-8?q?=E7=A6=BB=E7=BA=BF=E5=B7=A1=E6=A3=80=E6=97=A5=E5=BF=97=E4=B8=8D?= =?UTF-8?q?=E8=A6=81=E5=B1=95=E7=A4=BA]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Sonnet 4.6 Co-authored-by: multica-agent --- api/app/tasks/worker_registry_tasks.py | 6 +++++- web/src/app/admin/task-monitor/page.tsx | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) 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(() => {