{t('task_channel_locked')}
+ {runStatus &&{runStatus}
} {error &&{error}
}
diff --git a/docs/zh/tools/scheduler.mdx b/docs/zh/tools/scheduler.mdx
index 44cd8f5e..bf4f6dc7 100644
--- a/docs/zh/tools/scheduler.mdx
+++ b/docs/zh/tools/scheduler.mdx
@@ -34,11 +34,12 @@ description: 创建和管理定时任务
- "每隔 2 小时检查一下服务器状态"
- "明天下午 3 点提醒我开会"
- "查看所有定时任务"
-- "立即执行任务 a1b2c3d4"
-## 立即执行已有任务
+## 测试执行已有任务
-使用任务 ID 调用 `action="run"`，可以排队进行一次即时测试执行。禁用状态的任务也可手动执行，且不会因此被启用、删除或重新调度，原有 `next_run_at` 保持不变。同一任务正在按计划执行时，不允许重复手动执行。
+在经过身份认证的 Web 控制台或 Desktop 应用中打开任务，点击 **立即执行**。确认发送后，CowAgent 会立即按任务已配置的通道和接收者执行一次。这个入口只允许用户手动触发，不会暴露给 Agent 的 scheduler tool。
+
+禁用状态的任务也可手动执行，且不会因此被启用、删除或重新调度，原有 `next_run_at` 保持不变。同一任务正在按计划执行时，不允许重复手动执行。
diff --git a/tests/test_scheduler_run_now.py b/tests/test_scheduler_run_now.py
index 71cf990b..b8301bc2 100644
--- a/tests/test_scheduler_run_now.py
+++ b/tests/test_scheduler_run_now.py
@@ -3,7 +3,6 @@
import threading
import time
from datetime import datetime, timedelta
-from unittest.mock import Mock, patch
import pytest
@@ -72,18 +71,7 @@ def test_manual_run_rejects_duplicate_execution(tmp_path):
release.set()
-def test_scheduler_tool_queues_existing_task():
- store = Mock()
- store.get_task.return_value = {"id": "task-1", "name": "refresh index"}
- service = Mock()
- tool = SchedulerTool()
- tool.task_store = store
+def test_scheduler_tool_does_not_expose_manual_execution():
+ actions = SchedulerTool.params["properties"]["action"]["enum"]
- with patch(
- "agent.tools.scheduler.integration.get_scheduler_service",
- return_value=service,
- ):
- result = tool.execute({"action": "run", "task_id": "task-1"})
-
- assert result.status == "success"
- service.run_task_now.assert_called_once_with("task-1")
+ assert "run" not in actions
diff --git a/tests/test_scheduler_web_update.py b/tests/test_scheduler_web_update.py
index 2b423ce2..8a7c240d 100644
--- a/tests/test_scheduler_web_update.py
+++ b/tests/test_scheduler_web_update.py
@@ -4,7 +4,8 @@ import json
import sys
import types
from datetime import datetime, timedelta
-from unittest.mock import patch
+from pathlib import Path
+from unittest.mock import Mock, patch
from agent.tools.scheduler.task_store import TaskStore
@@ -28,7 +29,9 @@ if "web" not in sys.modules:
)
sys.modules["web"] = web_stub
-from channel.web.web_channel import SchedulerUpdateHandler
+from channel.web import web_channel
+
+SchedulerUpdateHandler = web_channel.SchedulerUpdateHandler
def _store_task(tmp_path, action):
@@ -54,6 +57,57 @@ def _post_update(tmp_path, payload):
return json.loads(SchedulerUpdateHandler().POST())
+def test_web_manual_run_is_authenticated_and_delegates_to_scheduler():
+ assert hasattr(web_channel, "SchedulerRunHandler")
+
+ service = Mock()
+ with patch("channel.web.web_channel._require_auth") as require_auth, \
+ patch("channel.web.web_channel.web.header"), \
+ patch("channel.web.web_channel.web.data", return_value=b'{"task_id":"task-1"}'), \
+ patch("agent.tools.scheduler.integration.get_scheduler_service", return_value=service):
+ response = json.loads(web_channel.SchedulerRunHandler().POST())
+
+ require_auth.assert_called_once_with()
+ service.run_task_now.assert_called_once_with("task-1")
+ assert response == {
+ "status": "success",
+ "message": "Task 'task-1' queued for immediate execution",
+ }
+
+
+def test_web_manual_run_rejects_unavailable_scheduler():
+ assert hasattr(web_channel, "SchedulerRunHandler")
+
+ with patch("channel.web.web_channel._require_auth"), \
+ patch("channel.web.web_channel.web.header"), \
+ patch("channel.web.web_channel.web.data", return_value=b'{"task_id":"task-1"}'), \
+ patch("agent.tools.scheduler.integration.get_scheduler_service", return_value=None):
+ response = json.loads(web_channel.SchedulerRunHandler().POST())
+
+ assert response == {
+ "status": "error",
+ "message": "Scheduler service is not running",
+ }
+
+
+def test_manual_run_is_exposed_by_explicit_web_and_desktop_controls():
+ root = Path(__file__).parents[1]
+ web_source = (root / "channel/web/web_channel.py").read_text(encoding="utf-8")
+ web_console = (root / "channel/web/static/js/console.js").read_text(encoding="utf-8")
+ desktop_client = (root / "desktop/src/renderer/src/api/client.ts").read_text(encoding="utf-8")
+ desktop_page = (root / "desktop/src/renderer/src/pages/TasksPage.tsx").read_text(encoding="utf-8")
+
+ assert "'/api/scheduler/run', 'SchedulerRunHandler'" in web_source
+ assert "function runTaskNow(task, button)" in web_console
+ assert "fetch('/api/scheduler/run'" in web_console
+ web_run = web_console[web_console.index("function runTaskNow(task, button)"):]
+ assert "showConfirmDialog({" in web_run[:2500]
+ assert "async runTask(taskId: string)" in desktop_client
+ assert "'/api/scheduler/run'" in desktop_client
+ assert "const runNow = async ()" in desktop_page
+ assert "window.confirm(t('task_run_confirm'))" in desktop_page
+
+
def test_web_edit_preserves_hidden_agent_action_fields(tmp_path):
store = _store_task(tmp_path, {
"type": "agent_task",