fix(workflow): 补 reExecute 后再次 Insert 分支的 LastHeartbeat，消除 30s 僵尸双跑窗口

2026-08-25 17:04:49 +08:00
parent ce2407bb2d
commit 36b10ae8e7
1 changed files with 1 additions and 0 deletions
@@ -390,6 +390,7 @@ func execute(ctx context.Context, conn *wsCommon.WsConnection, execId int64, sta
 				NodeGroupId:   nodeGroupId,
 				Status:        flow.FlowExecutionStatusRunning.Code(),
 				RequestParams: req.FlowContent,
+				LastHeartbeat: time.Now().UnixMilli(),
 			})
 			if err != nil || g.IsEmpty(execId) {
 				glog.Errorf(ctx, "工作流执行记录创建失败: %v", err)