Method request_domain_task_cancel

src/web/task_manager.py:573–579

(self, domain: str, task_id: str)

            return [self._domain_task_snapshot(item) for item in tasks[:safe_limit]]

    def request_domain_task_cancel(self, domain: str, task_id: str) -> Optional[Dict[str, Any]]:
        with _domain_lock:
            task = self._ensure_domain_task_locked(domain=domain, task_id=task_id)
            task["cancel_requested"] = True
            if str(task.get("status") or "").lower() in {"pending", "running"}:
                task["message"] = "已提交取消请求，等待任务结束"
            return self._domain_task_snapshot(task)

    def is_domain_task_cancel_requested(self, domain: str, task_id: str) -> bool:
        with _domain_lock: