diff --git a/api/internal/logic/inference/imageinferencelogic.go b/api/internal/logic/inference/imageinferencelogic.go
index f10a3c53..e37265ab 100644
--- a/api/internal/logic/inference/imageinferencelogic.go
+++ b/api/internal/logic/inference/imageinferencelogic.go
@@ -115,7 +115,7 @@ func (l *ImageInferenceLogic) ImageInfer(r *http.Request, req *types.ImageInfere
 
 	l.svcCtx.Scheduler.AiStorages.AddNoticeInfo(opt.AdapterId, adapterName, "", "", opt.TaskName, "create", "任务创建中")
 
-	go l.svcCtx.Scheduler.AiService.ImageInfer(opt, id, adapterName, clusters, ts, l.ctx)
+	go l.svcCtx.Scheduler.AiService.ImageInfer(opt, id, adapterName, clusters, ts)
 
 	return resp, nil
 }
diff --git a/api/internal/scheduler/service/aiService.go b/api/internal/scheduler/service/aiService.go
index 1e1d9df0..6d07a8e7 100644
--- a/api/internal/scheduler/service/aiService.go
+++ b/api/internal/scheduler/service/aiService.go
@@ -1,8 +1,7 @@
 package service
 
 import (
-	"context"
-	"fmt"
+	"github.com/zeromicro/go-zero/core/logx"
 	"github.com/zeromicro/go-zero/zrpc"
 	hpcacclient "gitlink.org.cn/JointCloud/pcm-ac/hpcacclient"
 	"gitlink.org.cn/JointCloud/pcm-coordinator/api/internal/config"
@@ -17,6 +16,7 @@ import (
 	"gitlink.org.cn/JointCloud/pcm-modelarts/client/imagesservice"
 	"gitlink.org.cn/JointCloud/pcm-modelarts/client/modelartsservice"
 	"gitlink.org.cn/JointCloud/pcm-octopus/octopusclient"
+	"net/http"
 	"strconv"
 	"sync"
 )
@@ -91,13 +91,14 @@ func InitAiClusterMap(conf *config.Config, clusters []types.ClusterInfo) (map[st
 	return executorMap, collectorMap
 }
 
-func (as *AiService) ImageInfer(opt *option.InferOption, id int64, adapterName string, clusters []*strategy.AssignedCluster, ts []*inference.ImageFile, ctx context.Context) {
+func (as *AiService) ImageInfer(opt *option.InferOption, id int64, adapterName string, clusters []*strategy.AssignedCluster, ts []*inference.ImageFile) {
 
-	res, err := inference.Infer(opt, id, adapterName, clusters, ts, as.AiCollectorAdapterMap, as.Storage, ctx)
+	r := http.Request{}
+	_, err := inference.Infer(opt, id, adapterName, clusters, ts, as.AiCollectorAdapterMap, as.Storage, r.Context())
 	if err != nil {
+		logx.Errorf(err.Error())
 		return
 	}
-	fmt.Println(res)
 }
 
 //func (a *AiService) AddCluster() error {