fix bug

server/workerManager.go

@@ -414,8 +414,9 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
 				log.WithField("worker", worker.uuid).Error("task not found for verify result")
 				continue
 			}
+			dtask := data.(*dispatchTask)
 
-			task := data.(*odysseus.TaskContent)
+			task := dtask.task
 			if result.TaskId != task.TaskId {
 				log.WithField("worker", worker.uuid).Error("task id not match")
 				continue
@@ -500,7 +501,7 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 				return
 			case *omanager.WorkerMessage_SubmitTaskAck:
 				if v, ok := worker.recentTask.Get(msg.SubmitTaskAck.TaskId); ok {
-					dtask := v.(dispatchTask)
+					dtask := v.(*dispatchTask)
 					select {
 					case dtask.ack <- true:
 						log.WithField("task", dtask.task.TaskId).Debug("got ack")