From 61daf732bd1b4e4a28e9d510b2de95197de18d59 Mon Sep 17 00:00:00 2001 From: hantmac Date: Fri, 29 Nov 2019 13:52:03 +0800 Subject: [PATCH] =?UTF-8?q?bug=20fix:=E4=BF=AE=E5=A4=8D=E6=89=8B=E5=8A=A8?= =?UTF-8?q?=E6=88=96=E8=80=85=E8=87=AA=E5=8A=A8=E5=88=A0=E9=99=A4=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E5=90=8E=E7=9A=84=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/services/task.go | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) diff --git a/backend/services/task.go b/backend/services/task.go index 9336e75d..14a609ad 100644 --- a/backend/services/task.go +++ b/backend/services/task.go @@ -468,6 +468,29 @@ func GetTaskLog(id string) (logStr string, err error) { } if IsMasterNode(task.NodeId.Hex()) { + if !utils.Exists(task.LogPath) { + fileDir, err := MakeLogDir(task) + + if err != nil { + log.Errorf(err.Error()) + } + + fileP := GetLogFilePaths(fileDir) + + // 获取日志文件路径 + fLog, err := os.Create(fileP) + defer fLog.Close() + if err != nil { + log.Errorf("create task log file error: %s", fileP) + debug.PrintStack() + } + task.LogPath = fileP + if err := task.Save(); err != nil { + log.Errorf(err.Error()) + debug.PrintStack() + } + + } // 若为主节点,获取本机日志 logBytes, err := model.GetLocalLog(task.LogPath) if err != nil {