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