From 03c1cc46c4d872fd935a720fb35d18d66f7af41b Mon Sep 17 00:00:00 2001
From: wuban <jinfei.duan@wuban.net.cn>
Date: Fri, 22 Mar 2024 11:56:39 +0800
Subject: [PATCH] add task exec error handler

---
 nm/task_msg.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/nm/task_msg.go b/nm/task_msg.go
index 1c129a3..9c1d544 100644
--- a/nm/task_msg.go
+++ b/nm/task_msg.go
@@ -375,6 +375,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 					log.Error("Container resp output is nil")
 					taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp output is nil")
 					t.ExecTaskIdIsSuccess.Store(taskMsg.TaskId, true)
+					taskExecResult.TaskRespBody = readBody
 					return
 				}
 			}
@@ -662,7 +663,7 @@ func parseData(readBody []byte) interface{} {
 		log.WithError(err).Error("Parse json raw message failed")
 		return bytes.NewBuffer(readBody).String()
 	}
-	if m["output"] == nil {
+	if m["output"] == nil || len(m["output"]) == 0 {
 		log.WithField("output", nil).Warn("The container resp")
 		return nil
 	}
-- 
2.23.0