Skip to content

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

change log

parent c82ded52
Hide whitespace changes
Inline Side-by-side
Showing with 14 additions and 2 deletions
server/taskresult.go
View file @ cc1377a3
...@@ -24,7 +24,13 @@ func (wm *WorkerManager) taskResult(worker *Worker, task *odysseus.TaskContent, ...@@ -24,7 +24,13 @@ func (wm *WorkerManager) taskResult(worker *Worker, task *odysseus.TaskContent,
} }
func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskContent, result *omanager.SubmitTaskResult) (*omanager.ManagerMessage_ProofTaskResult, error) { func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskContent, result *omanager.SubmitTaskResult) (*omanager.ManagerMessage_ProofTaskResult, error) {
log.WithField("task-id", task.TaskId).WithField("result", result).Debug("got task result") log.WithFields(log.Fields{
"task-id": task.TaskId,
"task-type": task.TaskType,
"task-kind": task.TaskKind,
"task-success": result.IsSuccessed,
"task-execute-duration": result.TaskExecuteDuration,
}).Debug("got task result")
if result.IsSuccessed == false { if result.IsSuccessed == false {
taskResponse := &odysseus.TaskResponse{ taskResponse := &odysseus.TaskResponse{
...@@ -98,7 +104,13 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo ...@@ -98,7 +104,13 @@ func (wm *WorkerManager) computeTaskResult(worker *Worker, task *odysseus.TaskCo
} }
func (wm *WorkerManager) standardTaskResult(worker *Worker, task *odysseus.TaskContent, result *omanager.SubmitTaskResult) (*omanager.ManagerMessage_ProofTaskResult, error) { func (wm *WorkerManager) standardTaskResult(worker *Worker, task *odysseus.TaskContent, result *omanager.SubmitTaskResult) (*omanager.ManagerMessage_ProofTaskResult, error) {
log.WithField("task-id", task.TaskId).WithField("result", result).Debug("got standard task result") log.WithFields(log.Fields{
"task-id": task.TaskId,
"task-type": task.TaskType,
"task-kind": task.TaskKind,
"task-success": result.IsSuccessed,
"task-execute-duration": result.TaskExecuteDuration,
}).Debug("got task result")
if result.IsSuccessed == false { if result.IsSuccessed == false {
receipt := wm.makeReceipt(worker, task, result, errors.New("worker failed")) receipt := wm.makeReceipt(worker, task, result, errors.New("worker failed"))
......
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