From 4bb73e56298f7bf0f795cbe4eacdb186a6b37cf1 Mon Sep 17 00:00:00 2001 From: qiwang <1364512070@qq.com> Date: Wed, 20 Aug 2025 10:28:37 +0800 Subject: [PATCH 1/3] fix:Modify input to dataset_input --- internal/storeLink/modelarts.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/storeLink/modelarts.go b/internal/storeLink/modelarts.go index af3c517c..99aa5d53 100644 --- a/internal/storeLink/modelarts.go +++ b/internal/storeLink/modelarts.go @@ -183,7 +183,7 @@ func (m *ModelArtsLink) SubmitTask(ctx context.Context, imageId string, cmd stri } if len(datasetsId) != 0 { inputs = append(inputs, &modelarts.InputTraining{ - Name: "input", + Name: "dataset_input", AccessMethod: "parameter", Remote: &modelarts.RemoteTra{ Obs: &modelarts.ObsTra{ From 98d8c94ff2e431724d026a28e73ba8318865776b Mon Sep 17 00:00:00 2001 From: tzwang Date: Thu, 21 Aug 2025 10:54:40 +0800 Subject: [PATCH 2/3] update ai service adapterid --- internal/scheduler/service/aiService.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/internal/scheduler/service/aiService.go b/internal/scheduler/service/aiService.go index 5d5af117..f7b00e78 100644 --- a/internal/scheduler/service/aiService.go +++ b/internal/scheduler/service/aiService.go @@ -41,11 +41,13 @@ type AiService struct { } func NewAiService(conf *config.Config, storages *database.AiStorage, localCache map[string]interface{}) (*AiService, error) { - var aiType = "1" - adapterIds, err := storages.GetAdapterIdsByType(aiType) - if err != nil { - return nil, err - } + //var aiType = "1" + var tempAdapterId = "1777144940459986944" + adapterIds := []string{tempAdapterId} + //adapterIds, err := storages.GetAdapterIdsByType(aiType) + //if err != nil { + // return nil, err + //} aiService := &AiService{ AiExecutorAdapterMap: make(map[string]map[string]executor.AiExecutor), AiCollectorAdapterMap: make(map[string]map[string]collector.AiCollector), @@ -106,7 +108,7 @@ func InitAiClusterMap(conf *config.Config, clusters []types.ClusterInfo) (map[st inferenceMap[c.Id] = sgai case OPENI: id, _ := strconv.ParseInt(c.Id, 10, 64) - openi := storeLink.NewOpenI(c.Server, id, c.Username, c.Token, c.Nickname) + openi := storeLink.NewOpenI("http://localhost:2024", id, c.Username, c.Token, c.Nickname) collectorMap[c.Id] = openi executorMap[c.Id] = openi inferenceMap[c.Id] = openi From 99d47f45f0b3fc433ea3497f07511b8bc384c36d Mon Sep 17 00:00:00 2001 From: tzwang Date: Thu, 21 Aug 2025 11:03:29 +0800 Subject: [PATCH 3/3] update ai service --- internal/scheduler/service/aiService.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/scheduler/service/aiService.go b/internal/scheduler/service/aiService.go index f7b00e78..254f19ba 100644 --- a/internal/scheduler/service/aiService.go +++ b/internal/scheduler/service/aiService.go @@ -108,7 +108,7 @@ func InitAiClusterMap(conf *config.Config, clusters []types.ClusterInfo) (map[st inferenceMap[c.Id] = sgai case OPENI: id, _ := strconv.ParseInt(c.Id, 10, 64) - openi := storeLink.NewOpenI("http://localhost:2024", id, c.Username, c.Token, c.Nickname) + openi := storeLink.NewOpenI(c.Server, id, c.Username, c.Token, c.Nickname) collectorMap[c.Id] = openi executorMap[c.Id] = openi inferenceMap[c.Id] = openi