Commit 4da93b1a authored by vicotor's avatar vicotor

fix bug

parent de1cac6f
...@@ -391,16 +391,19 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error { ...@@ -391,16 +391,19 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
log.WithField("worker", worker.uuid).Error("task id not match") log.WithField("worker", worker.uuid).Error("task id not match")
continue continue
} }
if task.TaskKind != odysseus.TaskKind_StandardTask {
_ = wm.AddWorkerSingle(worker)
}
proof, err := wm.taskResult(worker, task, result) proof, err := wm.taskResult(worker, task, result)
if err != nil { if err != nil {
log.WithError(err).Error("task result failed")
continue continue
} }
_ = proof _ = proof
worker.recentTask.Remove(result.TaskId) worker.recentTask.Remove(result.TaskId)
if task.TaskKind != odysseus.TaskKind_StandardTask { if task.TaskKind != odysseus.TaskKind_StandardTask {
_ = wm.AddWorkerSingle(worker)
wm.Payment(task) wm.Payment(task)
} }
} }
......
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