add new field

server/workerManager.go

@@ -304,13 +304,14 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
 
 			if result.IsSuccessed == false {
 				taskResponse := &odysseus.TaskResponse{
-					TaskUuid:         task.TaskUuid,
-					TaskResultHeader: result.TaskResultHeader,
-					TaskResultBody:   result.TaskResultBody,
-					TaskUid:          task.TaskUid,
-					TaskFee:          task.TaskFee,
-					TaskIsSucceed:    false,
-					TaskError:        "worker failed",
+					TaskUuid:            task.TaskUuid,
+					TaskResultHeader:    result.TaskResultHeader,
+					TaskResultBody:      result.TaskResultBody,
+					TaskUid:             task.TaskUid,
+					TaskFee:             task.TaskFee,
+					TaskIsSucceed:       false,
+					TaskError:           "worker failed",
+					TaskExecuteDuration: result.TaskExecuteDuration,
 				}
 				receipt := wm.makeReceipt(worker, task, result, errors.New("worker failed"))
 				wm.node.PostResult(receipt)
@@ -374,13 +375,14 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
 					worker.recentTask.Remove(result.TaskUuid)
 				}
 				taskResponse := &odysseus.TaskResponse{
-					TaskUuid:         task.TaskUuid,
-					TaskResultHeader: result.TaskResultHeader,
-					TaskResultBody:   result.TaskResultBody,
-					TaskUid:          task.TaskUid,
-					TaskFee:          task.TaskFee,
-					TaskIsSucceed:    true,
-					TaskError:        "",
+					TaskUuid:            task.TaskUuid,
+					TaskResultHeader:    result.TaskResultHeader,
+					TaskResultBody:      result.TaskResultBody,
+					TaskUid:             task.TaskUid,
+					TaskFee:             task.TaskFee,
+					TaskIsSucceed:       true,
+					TaskError:           "",
+					TaskExecuteDuration: result.TaskExecuteDuration,
 				}
 				go wm.doCallback(task.TaskCallback, taskResponse)