Commit 9f8679df authored by duanjinfei's avatar duanjinfei

update task exec error resp

parent 601afeec
...@@ -100,6 +100,9 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -100,6 +100,9 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
TaskExecTime: 0, TaskExecTime: 0,
TaskExecError: "", TaskExecError: "",
} }
t.Mutex.Lock()
t.LruCache.Add(taskMsg.TaskId, taskExecResult)
t.Mutex.Unlock()
taskCmd := &models.TaskCmd{} taskCmd := &models.TaskCmd{}
err := json.Unmarshal(bytes.NewBufferString(taskMsg.TaskCmd).Bytes(), taskCmd) err := json.Unmarshal(bytes.NewBufferString(taskMsg.TaskCmd).Bytes(), taskCmd)
if err != nil { if err != nil {
...@@ -433,9 +436,6 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -433,9 +436,6 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
} else if taskMsg.TaskKind == baseV1.TaskKind_StandardTask { } else if taskMsg.TaskKind == baseV1.TaskKind_StandardTask {
t.IsExecStandardTask = false t.IsExecStandardTask = false
} }
t.Mutex.Lock()
t.LruCache.Add(taskMsg.TaskId, taskExecResult)
t.Mutex.Unlock()
//log.WithField("result", taskExecResult).Info("lru cache storage task result") //log.WithField("result", taskExecResult).Info("lru cache storage task result")
log.Info("received computeTask--------------------------------") log.Info("received computeTask--------------------------------")
} }
......
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