Skip to content

N
nodemanager
Commit 7d0849c3 authored by vicotor's avatar vicotor
Browse files
Options

update

parent f06ff6e3
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
server/workerManager.go
View file @ 7d0849c3
...@@ -258,7 +258,7 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error { ...@@ -258,7 +258,7 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
callback = func(err error) bool { callback = func(err error) bool {
if err == nil { if err == nil {
// add task to cache. // add task to cache.
worker.recentTask.Add(task.TaskId, task) worker.recentTask.Add(task.TaskUuid, task)
} }
log.WithField("worker", worker.uuid).Info("dispatch task to worker") log.WithField("worker", worker.uuid).Info("dispatch task to worker")
......
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