|
|
@@ -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)
|