diff --git a/controller/task_video.go b/controller/task_video.go index 3f2c9588..a2c2431d 100644 --- a/controller/task_video.go +++ b/controller/task_video.go @@ -104,9 +104,7 @@ func updateVideoSingleTask(ctx context.Context, adaptor channel.TaskAdaptor, cha case "succeed": task.Status = model.TaskStatusSuccess task.Progress = "100%" - if url, err := adaptor.(interface { - ParseResultUrl(map[string]any) (string, error) - }).ParseResultUrl(responseItem); err == nil { + if url, err := adaptor.ParseResultUrl(responseItem); err == nil { task.FailReason = url } else { common.LogWarn(ctx, fmt.Sprintf("Failed to get url from body for task %s: %s", task.TaskID, err.Error())) diff --git a/relay/channel/task/kling/adaptor.go b/relay/channel/task/kling/adaptor.go index 9c6773f5..9ea58728 100644 --- a/relay/channel/task/kling/adaptor.go +++ b/relay/channel/task/kling/adaptor.go @@ -107,7 +107,7 @@ func (a *TaskAdaptor) BuildRequestURL(info *relaycommon.TaskRelayInfo) (string, func (a *TaskAdaptor) BuildRequestHeader(c *gin.Context, req *http.Request, info *relaycommon.TaskRelayInfo) error { token, err := a.createJWTToken() if err != nil { - token = info.ApiKey // fallback + return fmt.Errorf("failed to create JWT token: %w", err) } req.Header.Set("Content-Type", "application/json")