Commit a55e7327 authored by duanjinfei's avatar duanjinfei

update log print

parent 3c78c6ee
...@@ -286,7 +286,7 @@ func handlerMsg(nodeManager *models.NodeManagerClient, ...@@ -286,7 +286,7 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
taskMsgWorker.TaskMsg <- taskMsg taskMsgWorker.TaskMsg <- taskMsg
taskMsgWorker.Wg.Wait() taskMsgWorker.Wg.Wait()
taskExecResInterface, _ := taskMsgWorker.LruCache.Get(taskMsg.TaskId) taskExecResInterface, _ := taskMsgWorker.LruCache.Get(taskMsg.TaskId)
log.WithField("result", taskExecResInterface).Info("lru cache get task result") //log.WithField("result", taskExecResInterface).Info("lru cache get task result")
taskExecRes := taskExecResInterface.(*models.TaskResult) taskExecRes := taskExecResInterface.(*models.TaskResult)
if taskExecResInterface == nil { if taskExecResInterface == nil {
taskExecRes = &models.TaskResult{ taskExecRes = &models.TaskResult{
......
...@@ -285,7 +285,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -285,7 +285,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
t.IsExecStandardTask = false t.IsExecStandardTask = false
} }
t.LruCache.Add(taskMsg.TaskId, taskExecResult) t.LruCache.Add(taskMsg.TaskId, taskExecResult)
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