Commit 471e84fb authored by duanjinfei's avatar duanjinfei

update TaskRespBody

parent e64ea17b
...@@ -286,15 +286,9 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -286,15 +286,9 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
taskExecResult.TaskHttpStatusCode = models.RedirectCode taskExecResult.TaskHttpStatusCode = models.RedirectCode
post.Header.Set("Location", ossUri) post.Header.Set("Location", ossUri)
} }
} else {
taskExecResult.TaskRespBody = respBody
} }
} else {
taskExecResult.TaskRespBody = respBody
} }
} }
} else {
taskExecResult.TaskRespBody = readBody
} }
} }
headers, err := json.Marshal(post.Header) headers, err := json.Marshal(post.Header)
...@@ -303,9 +297,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -303,9 +297,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
return return
} }
log.WithField("headers", post.Header).Info("return task http headers") log.WithField("headers", post.Header).Info("return task http headers")
if taskMsg.TaskKind == baseV1.TaskKind_StandardTask { taskExecResult.TaskRespBody = readBody
taskExecResult.TaskRespBody = readBody
}
taskExecResult.TaskHttpHeaders = headers taskExecResult.TaskHttpHeaders = headers
taskExecResult.TaskIsSuccess = true taskExecResult.TaskIsSuccess = true
taskExecResult.TaskExecTime = endAfterTaskTime.Microseconds() taskExecResult.TaskExecTime = endAfterTaskTime.Microseconds()
......
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