Skip to content

N
nodemanager
Commit 1dda8b57 authored by vicotor's avatar vicotor
Browse files
Options

fix bug

parent 8d9cb73f
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 0 deletions
server/workerManager.go
View file @ 1dda8b57
......@@ -670,6 +670,9 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
go reg.Start()
wm.SetWorkerRegistry(worker.uuid, reg)
if e := wm.setWorkerLastTaskTime(worker, time.Now().Unix()); e != nil {
log.WithField("worker", worker.uuid).WithError(e).Error("set worker last task time failed")
}
default:
l.WithField("worker-addr", worker.workerAddr).Error(fmt.Sprintf("unsupport msg type %T", msg))
......
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