diff --git a/controller/task_video.go b/controller/task_video.go index 86095307d..d7c19e620 100644 --- a/controller/task_video.go +++ b/controller/task_video.go @@ -74,7 +74,13 @@ func updateVideoSingleTask(ctx context.Context, adaptor channel.TaskAdaptor, cha logger.LogError(ctx, fmt.Sprintf("Task %s not found in taskM", taskId)) return fmt.Errorf("task %s not found", taskId) } - resp, err := adaptor.FetchTask(baseURL, channel.Key, map[string]any{ + key := channel.Key + + privateData := task.PrivateData + if privateData.Key != "" { + key = privateData.Key + } + resp, err := adaptor.FetchTask(baseURL, key, map[string]any{ "task_id": taskId, "action": task.Action, }, proxy)