Commit 4b607e05 authored by vicotor's avatar vicotor

fix bug

parent 8b688a78
......@@ -156,16 +156,6 @@ func (wm *WorkerManager) standardTaskResult(worker *Worker, task *odysseus.TaskC
// todo: handle signature verify failed
}
}
taskResponse := &odysseus.TaskResponse{
TaskId: task.TaskId,
TaskResultHeader: result.TaskResultHeader,
TaskResultBody: result.TaskResultBody,
TaskUid: task.TaskUid,
TaskFee: task.TaskFee,
TaskIsSucceed: true,
TaskError: "",
}
go wm.doCallback(task.TaskCallback, taskResponse)
receipt := wm.makeReceipt(worker, task, result, Succeed)
wm.node.PostResult(receipt)
......
......@@ -410,6 +410,8 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
}
pushTask.TaskParam = []byte(param)
pushTask.TaskInLen = int32(len(param))
pushTask.TaskUid = "0"
pushTask.TaskTimestamp = uint64(time.Now().UnixNano())
pushTask.TaskKind = odysseus.TaskKind_StandardTask
pushTask.TaskFee = "0"
worker.taskCh <- &dispatchTask{
......
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