From 86b4803683a3252de3962106fbf5747fe983aa21 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=85=AC=E6=98=8E?=
 <83812544+Ed1s0nZ@users.noreply.github.com>
Date: Sat, 27 Jun 2026 01:40:12 +0800
Subject: [PATCH] Add files via upload

---
 internal/handler/agent.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/internal/handler/agent.go b/internal/handler/agent.go
index f9c1eed1..a3893178 100644
--- a/internal/handler/agent.go
+++ b/internal/handler/agent.go
@@ -201,6 +201,7 @@ func (h *AgentHandler) CancelRunningTaskForConversation(conversationID string) {
 		return
 	}
 	h.cancelActiveMCPToolForConversation(conversationID)
+	h.tasks.AbortActiveEinoExecute(conversationID, "")
 	if ok, err := h.tasks.CancelTask(conversationID, ErrTaskCancelled); ok {
 		h.logger.Info("已取消会话运行中任务", zap.String("conversationId", conversationID))
 	} else if err != nil {
@@ -1421,6 +1422,7 @@ func (h *AgentHandler) CancelAgentLoop(c *gin.Context) {
 	var cause error = ErrTaskCancelled
 	msg := "已提交取消请求，任务将在当前步骤完成后停止。"
 	h.cancelActiveMCPToolForConversation(req.ConversationID)
+	h.tasks.AbortActiveEinoExecute(req.ConversationID, "")
 	ok, err := h.tasks.CancelTask(req.ConversationID, cause)
 	if err != nil {
 		h.logger.Error("取消任务失败", zap.Error(err))