Skip to content

P
power-node
Commit 40d0862a authored by duanjinfei's avatar duanjinfei
Browse files
Options

update task return result

parent ff45f73a
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 2 deletions
nm/task_msg.go
View file @ 40d0862a
...@@ -219,8 +219,8 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -219,8 +219,8 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
log.Error("received error: ", err) log.Error("received error: ", err)
return return
} }
isUseFileCache := true
if taskMsg.TaskKind != baseV1.TaskKind_StandardTask { if taskMsg.TaskKind != baseV1.TaskKind_StandardTask {
isUseFileCache := true
for key, value := range taskParam.Headers { for key, value := range taskParam.Headers {
if key == models.UseFileCache { if key == models.UseFileCache {
if value[0] == "0" { if value[0] == "0" {
...@@ -261,8 +261,11 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -261,8 +261,11 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
log.Error("JSON marshal header error: ", err) log.Error("JSON marshal header error: ", err)
return return
} }
log.WithField("headers", headers).Info("return task http headers")
if taskMsg.TaskKind == baseV1.TaskKind_StandardTask && !isUseFileCache {
taskExecResult.TaskRespBody = readBody
}
taskExecResult.TaskHttpHeaders = headers taskExecResult.TaskHttpHeaders = headers
taskExecResult.TaskRespBody = readBody
taskExecResult.TaskIsSuccess = true taskExecResult.TaskIsSuccess = true
taskExecResult.TaskExecTime = endAfterTaskTime.Microseconds() taskExecResult.TaskExecTime = endAfterTaskTime.Microseconds()
} else { } else {
......
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