add result code

server/taskresult.go

@@ -42,6 +42,7 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo
 			TaskUid:          task.TaskUid,
 			TaskFee:          task.TaskFee,
 			TaskIsSucceed:    false,
+			TaskResultCode:   result.TaskResultCode,
 			TaskError:        "worker failed",
 		}
 		receipt := wm.makeReceipt(worker, task, result, errors.New("worker failed"))
@@ -56,6 +57,7 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo
 			TaskUid:          task.TaskUid,
 			TaskFee:          task.TaskFee,
 			TaskIsSucceed:    true,
+			TaskResultCode:   result.TaskResultCode,
 			TaskError:        "",
 		}
 		go wm.doCallback(task.TaskCallback, taskResponse)

server/workerstatu.go

@@ -113,6 +113,8 @@ func (wm *WorkerManager) AddWorkerSingle(worker *Worker) error {
 		priority := 0
 		if err := wm.rdb.RPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(priority), workerId(worker)).Err(); err != nil {
 			log.WithError(err).Error("add worker back to queue failed.")
+		} else {
+			log.WithField("worker", worker.workerAddr).Info("add worker back to queue success.")
 		}
 	}
 	// add worker to redis queue