Commit ea57f47b authored by duanjinfei's avatar duanjinfei

submit task result body

parent e52f0eeb
...@@ -244,9 +244,7 @@ func SubmitResultResp(params ...interface{}) *nodemanagerV1.WorkerMessage { ...@@ -244,9 +244,7 @@ func SubmitResultResp(params ...interface{}) *nodemanagerV1.WorkerMessage {
TaskResultHeader: taskExecResult.TaskHttpHeaders, TaskResultHeader: taskExecResult.TaskHttpHeaders,
TaskExecuteDuration: uint64(taskExecResult.TaskExecTime), TaskExecuteDuration: uint64(taskExecResult.TaskExecTime),
IsSuccessed: isSuccess, IsSuccessed: isSuccess,
} TaskResultBody: taskExecResult.TaskRespBody,
if taskExecResult.TaskHttpStatusCode == 200 {
n.TaskResultBody = taskExecResult.TaskRespBody
} }
submitResultMsgRes := &nodemanagerV1.WorkerMessage{ submitResultMsgRes := &nodemanagerV1.WorkerMessage{
Message: &nodemanagerV1.WorkerMessage_SubmitTaskResult{ Message: &nodemanagerV1.WorkerMessage_SubmitTaskResult{
......
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