Skip to content

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

update protocol

parent de654bd0
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 2 deletions
server/taskresult.go
View file @ beb4e830
...@@ -47,7 +47,8 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo ...@@ -47,7 +47,8 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo
TaskUid: task.TaskUid, TaskUid: task.TaskUid,
TaskFee: task.TaskFee, TaskFee: task.TaskFee,
TaskIsSucceed: false, TaskIsSucceed: false,
TaskResultCode: result.TaskResultCode, TaskResultCode: result.TaskExecuteCode,
TaskExecuteError: result.TaskExecuteError,
TaskError: ErrExecuteFailed.Error(), TaskError: ErrExecuteFailed.Error(),
} }
receipt := wm.makeReceipt(worker, task, result, ErrExecuteFailed) receipt := wm.makeReceipt(worker, task, result, ErrExecuteFailed)
...@@ -62,7 +63,8 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo ...@@ -62,7 +63,8 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo
TaskUid: task.TaskUid, TaskUid: task.TaskUid,
TaskFee: task.TaskFee, TaskFee: task.TaskFee,
TaskIsSucceed: true, TaskIsSucceed: true,
TaskResultCode: result.TaskResultCode, TaskResultCode: result.TaskExecuteCode,
TaskExecuteError: result.TaskExecuteError,
TaskError: "", TaskError: "",
} }
go wm.doCallback(task.TaskCallback, taskResponse) go wm.doCallback(task.TaskCallback, taskResponse)
......
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