Commit 5a501677 authored by vicotor's avatar vicotor

update log

parent 75128321
...@@ -346,7 +346,6 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error { ...@@ -346,7 +346,6 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
TaskParam: task.TaskParam, TaskParam: task.TaskParam,
} }
msg.Message = taskMsg msg.Message = taskMsg
errCh := make(chan error, 1)
callback = func(err error) bool { callback = func(err error) bool {
if err == nil { if err == nil {
......
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