From 18d1f81bada0a6cafd9d10c26fb059dd3d9ab998 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E4=BF=8A=E6=96=87?= <lijunwen.gigoo@bytedance.com>
Date: Tue, 22 Jul 2025 10:08:42 +0000
Subject: [PATCH] fix: history round

* fix: agent rerun delete run record
* fix: history round

See merge request: !897
---
 backend/application/conversation/agent_run.go |  6 +++++
 .../agentrun/service/agent_run_impl.go        | 25 ++++++++++---------
 2 files changed, 19 insertions(+), 12 deletions(-)

diff --git a/backend/application/conversation/agent_run.go b/backend/application/conversation/agent_run.go
index df50f9bd..b648842b 100644
--- a/backend/application/conversation/agent_run.go
+++ b/backend/application/conversation/agent_run.go
@@ -69,6 +69,12 @@ func (c *ConversationApplicationService) Run(ctx context.Context, sseSender *sse
 			if msgMeta.UserID != conv.Int64ToStr(userID) {
 				return errorx.New(errno.ErrConversationPermissionCode, errorx.KV("msg", "message not match"))
 			}
+
+			err = c.AgentRunDomainSVC.Delete(ctx, []int64{msgMeta.RunID})
+			if err != nil {
+				return err
+			}
+
 			delErr := c.MessageDomainSVC.Delete(ctx, &msgEntity.DeleteMeta{
 				RunIDs: []int64{msgMeta.RunID},
 			})
diff --git a/backend/domain/conversation/agentrun/service/agent_run_impl.go b/backend/domain/conversation/agentrun/service/agent_run_impl.go
index 9cd62810..e041b82d 100644
--- a/backend/domain/conversation/agentrun/service/agent_run_impl.go
+++ b/backend/domain/conversation/agentrun/service/agent_run_impl.go
@@ -103,6 +103,19 @@ func (c *runImpl) AgentRun(ctx context.Context, arm *entity.AgentRunMeta) (*sche
 }
 
 func (c *runImpl) run(ctx context.Context, sw *schema.StreamWriter[*entity.AgentRunResponse], rtDependence *runtimeDependence) (err error) {
+
+	agentInfo, err := c.handlerAgent(ctx, rtDependence)
+	if err != nil {
+		return
+	}
+
+	rtDependence.agentInfo = agentInfo
+
+	history, err := c.handlerHistory(ctx, rtDependence)
+	if err != nil {
+		return
+	}
+
 	runRecord, err := c.createRunRecord(ctx, sw, rtDependence)
 
 	if err != nil {
@@ -122,18 +135,6 @@ func (c *runImpl) run(ctx context.Context, sw *schema.StreamWriter[*entity.Agent
 		c.runProcess.StepToComplete(ctx, srRecord, sw, rtDependence.usage)
 	}()
 
-	agentInfo, err := c.handlerAgent(ctx, rtDependence)
-	if err != nil {
-		return
-	}
-
-	rtDependence.agentInfo = agentInfo
-
-	history, err := c.handlerHistory(ctx, rtDependence)
-	if err != nil {
-		return
-	}
-
 	input, err := c.handlerInput(ctx, sw, rtDependence)
 	if err != nil {
 		return