Commit 3413f78e authored by vicotor's avatar vicotor

update error info

parent 7f33229e
...@@ -11,6 +11,10 @@ import ( ...@@ -11,6 +11,10 @@ import (
"time" "time"
) )
var (
ErrExecuteFailed = errors.New("execute failed")
)
func (wm *WorkerManager) taskResult(worker *Worker, task *odysseus.TaskContent, result *omanager.SubmitTaskResult) (*odysseus.TaskProof, error) { func (wm *WorkerManager) taskResult(worker *Worker, task *odysseus.TaskContent, result *omanager.SubmitTaskResult) (*odysseus.TaskProof, error) {
switch task.TaskKind { switch task.TaskKind {
case odysseus.TaskKind_ComputeTask: case odysseus.TaskKind_ComputeTask:
...@@ -43,7 +47,7 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo ...@@ -43,7 +47,7 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo
TaskFee: task.TaskFee, TaskFee: task.TaskFee,
TaskIsSucceed: false, TaskIsSucceed: false,
TaskResultCode: result.TaskResultCode, TaskResultCode: result.TaskResultCode,
TaskError: "worker failed", TaskError: ErrExecuteFailed.Error(),
} }
receipt := wm.makeReceipt(worker, task, result, errors.New("worker failed")) receipt := wm.makeReceipt(worker, task, result, errors.New("worker failed"))
wm.node.PostResult(receipt) wm.node.PostResult(receipt)
......
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