From 36b10ae8e7abd16f60735ef331b790c7c81d9657 Mon Sep 17 00:00:00 2001 From: qhd <1766646056@qq.com> Date: Tue, 25 Aug 2026 17:04:49 +0800 Subject: [PATCH] =?UTF-8?q?fix(workflow):=20=E8=A1=A5=20reExecute=20?= =?UTF-8?q?=E5=90=8E=E5=86=8D=E6=AC=A1=20Insert=20=E5=88=86=E6=94=AF?= =?UTF-8?q?=E7=9A=84=20LastHeartbeat=EF=BC=8C=E6=B6=88=E9=99=A4=2030s=20?= =?UTF-8?q?=E5=83=B5=E5=B0=B8=E5=8F=8C=E8=B7=91=E7=AA=97=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- workflow/service/flow/flow_ws_exec.go | 1 + 1 file changed, 1 insertion(+) diff --git a/workflow/service/flow/flow_ws_exec.go b/workflow/service/flow/flow_ws_exec.go index 3f1b6eb..184d206 100644 --- a/workflow/service/flow/flow_ws_exec.go +++ b/workflow/service/flow/flow_ws_exec.go @@ -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)