add log and task result is nil

nm/start.go

@@ -286,7 +286,17 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
 						taskMsgWorker.TaskMsg <- taskMsg
 						taskMsgWorker.Wg.Wait()
 						taskExecResInterface, _ := taskMsgWorker.LruCache.Get(taskMsg.TaskId)
+						log.WithField("result", taskExecResInterface).Info("lru cache get task result")
 						taskExecRes := taskExecResInterface.(*models.TaskResult)
+						if taskExecResInterface == nil {
+							taskExecRes = &models.TaskResult{
+								TaskHttpStatusCode: 200,
+								TaskRespBody:       nil,
+								TaskHttpHeaders:    nil,
+								TaskIsSuccess:      false,
+								TaskExecTime:       0,
+							}
+						}
 						isSuccess := taskExecRes.TaskIsSuccess
 						containerSign := taskMsgWorker.DockerOp.GetContainerSign(taskMsg, taskExecRes.TaskRespBody)
 						if containerSign == nil || len(containerSign) == 0 {

nm/task_msg.go

@@ -229,8 +229,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 					}
 				}
 			}
+			log.WithField("isUseFileCache", isUseFileCache).Info("is use file cache")
 			if isUseFileCache && readBody != nil {
 				containerResp := &models.ModelResponse{}
+				log.WithField("task resp", readBody).Info("received response")
 				err = json.Unmarshal(readBody, &containerResp)
 				if err != nil {
 					log.WithError(err).Error("Error unmarshalling oss resp body failed")
@@ -283,6 +285,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 		t.IsExecStandardTask = false
 	}
 	t.LruCache.Add(taskMsg.TaskId, taskExecResult)
+	log.WithField("result", taskExecResult).Info("lru cache storage task result")
 	log.Info("received computeTask--------------------------------")
 }