Commit dbb8aeb3 authored by duanjinfei's avatar duanjinfei

add log

parent a44629ec
......@@ -53,6 +53,7 @@ func (n *NodeManagerHandler) DistributionMsgWorker(nodeManagerMsgChan chan *node
ackParams := utils.BuildParams(taskMsg.TaskId, isCanExecute, bootUpTime, queueWaitTime, executeTime)
msgRespWorker.RegisterMsgResp(n.nodeManager, n.worker, RespTaskAck, ackParams)
if !isCanExecute {
log.WithField("taskId", taskMsg.TaskId).Error("The task is not executed")
return
}
taskMsgWorker.Wg.Add(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