Skip to content

P
power-node
Commit c76f6bee authored by duanjinfei's avatar duanjinfei
Browse files
Options

resp body is nil and container sign failed

parent 7592abcf
Hide whitespace changes
Inline Side-by-side
Showing with 9 additions and 0 deletions
nm/task_msg.go
View file @ c76f6bee
...@@ -292,7 +292,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -292,7 +292,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
} }
ossUri, err := t.getFileCache(respStr, taskMsg, taskParam, taskCmd) ossUri, err := t.getFileCache(respStr, taskMsg, taskParam, taskCmd)
if err != nil || ossUri == "" { if err != nil || ossUri == "" {
taskExecResult.TaskExecError = fmt.Sprintf("%s,%s", taskExecResult.TaskExecError, err)
apiResOneArr = append(apiResOneArr, respStr) apiResOneArr = append(apiResOneArr, respStr)
apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
taskExecResult.TaskRespBody = apiResBody
continue continue
} }
if ossUri != "" && len(res) == 1 && len(innerSlice) == 1 { if ossUri != "" && len(res) == 1 && len(innerSlice) == 1 {
...@@ -324,7 +327,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -324,7 +327,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
} }
ossUri, err := t.getFileCache(respStr, taskMsg, taskParam, taskCmd) ossUri, err := t.getFileCache(respStr, taskMsg, taskParam, taskCmd)
if err != nil || ossUri == "" { if err != nil || ossUri == "" {
taskExecResult.TaskExecError = fmt.Sprintf("%s,%s", taskExecResult.TaskExecError, err)
apiRes = append(apiRes, respStr) apiRes = append(apiRes, respStr)
apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
taskExecResult.TaskRespBody = apiResBody
continue continue
} }
if ossUri != "" && len(res) == 1 { if ossUri != "" && len(res) == 1 {
...@@ -355,7 +361,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -355,7 +361,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
} }
ossUri, err := t.getFileCache(respStr, taskMsg, taskParam, taskCmd) ossUri, err := t.getFileCache(respStr, taskMsg, taskParam, taskCmd)
if err != nil || ossUri == "" { if err != nil || ossUri == "" {
taskExecResult.TaskExecError = fmt.Sprintf("%s,%s", taskExecResult.TaskExecError, err)
apiRes = append(apiRes, respStr) apiRes = append(apiRes, respStr)
apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
taskExecResult.TaskRespBody = apiResBody
continue continue
} }
if ossUri != "" && len(resArr) == 1 { if ossUri != "" && len(resArr) == 1 {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment