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)