diff --git a/controller/task_video.go b/controller/task_video.go index 8d4acdda8..9bbf7a902 100644 --- a/controller/task_video.go +++ b/controller/task_video.go @@ -97,7 +97,6 @@ func updateVideoSingleTask(ctx context.Context, adaptor channel.TaskAdaptor, cha taskResult.Url = t.FailReason taskResult.Progress = t.Progress taskResult.Reason = t.FailReason - task.Data = t.Data } else if taskResult, err = adaptor.ParseTaskResult(responseBody); err != nil { return fmt.Errorf("parseTaskResult failed for task %s: %w", taskId, err) } else { diff --git a/relay/relay_task.go b/relay/relay_task.go index d447a40aa..9cb8cd5c8 100644 --- a/relay/relay_task.go +++ b/relay/relay_task.go @@ -362,20 +362,11 @@ func videoFetchByIDRespBodyBuilder(c *gin.Context) (respBody []byte, taskResp *d } }() - if len(respBody) != 0 { - return - } - - if strings.HasPrefix(c.Request.RequestURI, "/v1/videos/") { - respBody = originTask.Data - return - } - respBody, err = json.Marshal(dto.TaskResponse[any]{ - Code: "success", - Data: TaskModel2Dto(originTask), - }) - if err != nil { - taskResp = service.TaskErrorWrapper(err, "marshal_response_failed", http.StatusInternalServerError) + if len(respBody) == 0 { + respBody, err = json.Marshal(dto.TaskResponse[any]{ + Code: "success", + Data: TaskModel2Dto(originTask), + }) } return }