JCCE
/
PCM
28
0
Fork 8
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

merge into: JCCE:master
Branches Tags
JCCE:master
JCCE:2.0
JCCE:fc
JCCE:2.0_gitlink
JCCE:2.0-zw
JCCE:2.0_wangqi_20230329
JCCE:2.0_wangqi_20230315
JCCE:pcm_modelarts_1.1
JCCE:pcm_modelarts_1.1_lee
JCCE:pcm_modelarts_1.1_wangqi
JCCE:pcm_modelarts_1.0
JCCE:pcm_modelarts_1.0_xd
JCCE:test
JCCE:slurm_shuguang
JCCE:slurm_core
JCCE:slurm_tianhe
JCCE:slurm-20.11.8-wtz
JCCE:slurm-20.11-wtz
JCCE:slurm-wtz
JCCE:slurm_cmd
JCCE:v0.1.4
JCCE:v0.1.3
JCCE:v0.1.2
JCCE:v0.1.1
JCCE:v0.1.0
...
pull from: JCCE:2.0_gitlink
Branches Tags
JCCE:2.0
JCCE:fc
JCCE:2.0_gitlink
JCCE:2.0-zw
JCCE:master
JCCE:2.0_wangqi_20230329
JCCE:2.0_wangqi_20230315
JCCE:pcm_modelarts_1.1
JCCE:pcm_modelarts_1.1_lee
JCCE:pcm_modelarts_1.1_wangqi
JCCE:pcm_modelarts_1.0
JCCE:pcm_modelarts_1.0_xd
JCCE:test
JCCE:slurm_shuguang
JCCE:slurm_core
JCCE:slurm_tianhe
JCCE:slurm-20.11.8-wtz
JCCE:slurm-20.11-wtz
JCCE:slurm-wtz
JCCE:slurm_cmd
JCCE:v0.1.4
JCCE:v0.1.3
JCCE:v0.1.2
JCCE:v0.1.1
JCCE:v0.1.0

45 Commits
master ... 2.0_gitlin

Author SHA1 Message Date
zhouqunjie 04009f68b6 repo url update 2023-07-11 14:48:35 +08:00
zhangwei 9e6d65053c 外部任务状态枚举修改 2023-07-11 10:33:41 +08:00
zhangwei 7ee7b0c5c4 镜像列表开发完成 2023-07-10 17:27:02 +08:00
zhangwei 0df5d171dc 镜像列表接口注释 开发中 2023-07-10 17:05:34 +08:00
tzwang 838077afc7 Merge remote-tracking branch 'origin/2.0' into 2.0 2023-07-10 10:30:44 +08:00
tzwang c6fb5065a6 octopus修改tokenservice代码 2023-07-10 10:28:37 +08:00
zhangwei ec61728338 修改镜像仓库配置 2023-07-07 16:46:16 +08:00
zhangwei fdd81a6b33 修改镜像仓库 2023-07-07 16:29:50 +08:00
zhangwei fba1807a5d 修改挂载配置 2023-07-07 16:02:09 +08:00
zhangwei 9c3325b8f4 修改挂载配置 2023-07-07 15:55:13 +08:00
zhangwei 426cab62ba 修改挂载配置 2023-07-07 15:47:41 +08:00
zhangwei 3a5cf8cbee 修改docker镜像源 2023-07-07 10:24:10 +08:00
zhangwei 6d2088c033 pcm-core-api yaml文件配置修改 2023-07-07 09:45:37 +08:00
zhangwei b65d509bd6 docker client配置连接修改成默认 2023-07-07 09:41:38 +08:00
zhangwei e49440f47f docker client配置连接 2023-07-06 16:07:05 +08:00
zhangwei 474a2bc77b 文件上传增加错误信息返回 2023-07-06 10:40:41 +08:00
zhangwei 64242fd919 文件上传增加错误信息返回 2023-07-06 10:32:44 +08:00
zhangwei bf0e6c6a09 Merge branch 'file2.0' into 2.0 2023-07-06 10:03:43 +08:00
zhangwei 1611ce4e7c 镜像管理完成 2023-07-06 10:03:21 +08:00
devad a0b8934eb3 feat: 新增腾讯云云函数，对接查询函数列表方法 
Signed-off-by: devad <cossjie@foxmail.com>
 2023-07-05 15:03:18 +08:00
zhangwei e35fb35fe3 推送文件到云集存储完成 2023-07-04 17:11:19 +08:00
zhangwei 4d246847cd 文件上传 2023-07-04 16:30:31 +08:00
zhangwei f7d1f70f11 Merge branch '2.0' into 2.0-zw 
# Conflicts:
#	adaptor/PCM-CORE/api/desc/core/pcm-core.api
#	adaptor/PCM-CORE/rpc/pcmcore.go
#	common/config/nacos.go
 2023-07-04 15:41:29 +08:00
zhangwei 8f0f03f780 文件上传 2023-07-04 15:36:50 +08:00
zhangwei 72f094fbec 文件上传 2023-07-04 11:47:24 +08:00
zhangwei 088cc41d99 大屏任务列表判空 2023-06-26 09:06:01 +08:00
zhangwei 34cdece43b 代码规范 2023-06-21 16:16:09 +08:00
zhangwei 6800f9a6d5 任务列表信息 2023-06-20 16:48:07 +08:00
devad 15f598faac fix: 域信息查询数算集群监控 
Signed-off-by: devad <cossjie@foxmail.com>
 2023-06-17 11:29:05 +08:00
zhangwei 43a5062326 对接任务数据增加返回体 2023-06-16 22:34:30 +08:00
zhangwei efcea561a7 对接任务数据 2023-06-16 22:03:17 +08:00
ll15074821352 64c14f9308 modelarts Core端api文件训练作业增加订阅算法参数 2023-06-16 16:08:28 +08:00
devad fa3519fe5c fix: 修复查询域资源信息赋值问题 
Signed-off-by: devad <cossjie@foxmail.com>
 2023-06-16 11:51:44 +08:00
qiwang d705dd41fe fix:PCM-ceph代码修改 2023-06-16 10:07:44 +08:00
zhouqunjie d6386bb55f add param type for listclusterlogic 2023-06-16 09:50:16 +08:00
ll15074821352 e30cbb370e modelarts Core端api文件训练作业增加订阅算法参数 2023-06-16 08:35:51 +08:00
zhouqunjie 8a9df31afa nacos config amend 2023-06-15 20:07:07 +08:00
zhouqunjie c64c2121c2 Merge remote-tracking branch 'origin/2.0' into 2.0 2023-06-15 18:38:31 +08:00
zhouqunjie e2d56722f5 pcm interface:list cluster for compute center 2023-06-15 18:38:24 +08:00
devad 7ff060d170 fix: nacos地址更改为配置 
Signed-off-by: devad <cossjie@foxmail.com>
 2023-06-15 18:03:24 +08:00
zhouqunjie 922d169796 Merge remote-tracking branch 'origin/2.0' into 2.0 2023-06-15 17:27:37 +08:00
zhouqunjie 94574bb562 ac list history job& pcm list cluster for compute center 2023-06-15 17:27:30 +08:00
ll15074821352 6acb3cf134 modelarts Core端api文件训练作业增加订阅算法参数 2023-06-15 16:24:09 +08:00
ll15074821352 585099db80 modelarts Core端api文件训练作业增加订阅算法参数 2023-06-15 09:44:45 +08:00
894646498@qq.com 156bfc9f20 nacos集成 2023-04-21 17:19:42 +08:00
337 changed files with 8517 additions and 5580 deletions
Show Stats Expand all files Collapse all files

4
adaptor/PCM-AI/PCM-MODELARTS/rpc/etc/pcmmodelarts.yaml
View File

@ -4,10 +4,10 @@ NacosConfig:
ServerConfigs:
# - IpAddr: 127.0.0.1
# Port: 8848
- IpAddr: 10.101.15.7
- IpAddr: nacos.jcce.dev
Port: 8848
ClientConfig:
NamespaceId: test
NamespaceId: zhouqj
TimeoutMs: 5000
NotLoadCacheAtStart: true
LogDir:

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createalgorithmlogic.go
View File

@ -1,16 +1,16 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createdatasetlogic.go
View File

@ -1,14 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createmodellogic.go
View File

@ -6,15 +6,15 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createnotebooklogic.go
View File

@ -1,15 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createprocessortasklogic.go
View File

@ -6,19 +6,19 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createservicelogic.go
View File

@ -6,14 +6,14 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createtasklogic.go
View File

@ -1,19 +1,19 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createtrainingjobconfiglogic.go
View File

@ -1,19 +1,19 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createtrainingjoblogic.go
View File

@ -1,14 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/createvisualizationjoblogic.go
View File

@ -1,19 +1,19 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

123
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/cronlogic.go
View File

@ -1,11 +1,11 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/adaptor/PCM-CORE/rpc/pcmcoreclient"
"context"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-CORE/rpc/pcmcoreclient"
"time"
)
@ -25,7 +25,7 @@ func InitCron(svc *svc.ServiceContext) {
}
// 提交任务
submitJob(infoList, submitJobLogic)
// 查询运行中的任务列表同步信息 吧吧你 你
// 查询运行中的任务列表同步信息
listReq := modelarts.ListTrainingJobsreq{
ProjectId: "0a62ffb0d48026c12fbfc011b8d23f0b",
Limit: 10,
@ -75,15 +75,120 @@ func submitJob(infoList *pcmcoreclient.InfoListResp, submitJobLogic *CreateTrain
Description: "This is a ModelArts Demo Job",
},
Algorithm: &modelarts.Algorithms{
Command: infoList.AiInfoList[index].Command,
Engine: &modelarts.EngineCreateTraining{
ImageUrl: infoList.AiInfoList[index].ImageUrl,
//SubscriptionId: infoList.AiInfoList[index].SubscriptionId,
//ItemVersionId: infoList.AiInfoList[index].ItemVersionId,
SubscriptionId: "26a0d9a9-808a-43f4-9a06-c9ea6bdc53d2",
ItemVersionId: "2.0.0",
//Command: infoList.AiInfoList[index].Command,
//Engine: &modelarts.EngineCreateTraining{
// ImageUrl: infoList.AiInfoList[index].ImageUrl,
//},
Parameters: []*modelarts.ParametersTrainJob{
{
Name: "do_train",
Value: "True",
},
{
Name: "do_eval_along_train",
Value: "True",
},
{
Name: "lr",
Value: "0.01",
},
{
Name: "epochs",
Value: "60",
},
{
Name: "batch_size",
Value: "64",
},
{
Name: "eval_batch_size",
Value: "64",
},
{
Name: "lr_scheduler",
Value: "cos",
},
{
Name: "lr_step",
Value: "20",
},
{
Name: "mixup",
Value: "0.2",
},
{
Name: "label_smoothing",
Value: "0.1",
},
{
Name: "warmup_epochs",
Value: "5",
},
{
Name: "rand_aug",
Value: "True",
},
{
Name: "num_workers",
Value: "8",
},
{
Name: "model_name",
Value: "resnest50",
},
{
Name: "use_dali",
Value: "False",
},
{
Name: "accumulation_steps",
Value: "1",
},
{
Name: "do_data_cleaning",
Value: "True",
},
{
Name: "max_to_keep",
Value: "10",
},
},
Inputs: []*modelarts.InputTraining{
{
Name: "data_url",
AccessMethod: "parameter",
Remote: &modelarts.RemoteTra{
Dataset: &modelarts.DatasetTra{
Id: "L0cTaBjZF61k27w8T74",
Name: "dataset-flower",
VersionName: "V001",
VersionId: "xBx4lPDk4rtf6mEex4W",
},
},
},
},
Outputs: []*modelarts.OutputTraining{
{
Name: "train_url",
AccessMethod: "parameter",
Remote: &modelarts.RemoteOut{
Obs: &modelarts.ObsTra{
ObsUrl: "/jointcloud-out1/flower/",
},
},
},
},
},
Spec: &modelarts.SpecsC{
Resource: &modelarts.ResourceCreateTraining{
FlavorId: infoList.AiInfoList[index].FlavorId,
NodeCount: 1,
FlavorId: infoList.AiInfoList[index].FlavorId,
NodeCount: 1,
Policy: "regular",
FlavorLabel: "[限时免费] GPU: 1*NVIDIA-V100(32GB) | CPU: 8 核 64GB 780GB",
},
},
}

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/deletealgorithmslogic.go
View File

@ -1,18 +1,18 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/deletedatasetlogic.go
View File

@ -1,18 +1,18 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/deletemodellogic.go
View File

@ -6,18 +6,18 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/deleteservicelogic.go
View File

@ -6,13 +6,13 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/deletetrainingjobconfiglogic.go
View File

@ -1,13 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/deletetrainingjoblogic.go
View File

@ -1,14 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/describeprocessortasklogic.go
View File

@ -6,13 +6,13 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

10
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/exporttasklogic.go
View File

@ -6,21 +6,21 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
_ "PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
_ "gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
)
type ExportTaskLogic struct {

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getaiengineslistlogic.go
View File

@ -1,17 +1,17 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getdatasetlistlogic.go
View File

@ -1,14 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getexporttasksofdatasetlogic.go
View File

@ -6,19 +6,19 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strconv"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
)
type GetExportTasksOfDatasetLogic struct {

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getexporttaskstatusofdatasetlogic.go
View File

@ -6,17 +6,17 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getimporttasklistlogic.go
View File

@ -1,11 +1,11 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"log"
@ -13,8 +13,8 @@ import (
"strconv"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getlisttrainingjobslogic.go
View File

@ -1,13 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getnotebookstoragelogic.go
View File

@ -1,18 +1,18 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

4
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/gettokenlogic.go
View File

@ -9,8 +9,8 @@ import (
"net/http"
"time"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/gettrainingjobflavorslogic.go
View File

@ -1,13 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/getvisualizationjoblogic.go
View File

@ -1,18 +1,18 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/listalgorithmslogic.go
View File

@ -1,15 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/listclusterslogic.go
View File

@ -6,18 +6,18 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"strconv"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/listmodelslogic.go
View File

@ -6,18 +6,18 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/listnotebooklogic.go
View File

@ -1,14 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/listserviceslogic.go
View File

@ -6,15 +6,15 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/listtrainingjobconfiglogic.go
View File

@ -1,16 +1,16 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"github.com/bitly/go-simplejson"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/mountnotebookstoragelogic.go
View File

@ -1,19 +1,19 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/showalgorithmbyuuidlogic.go
View File

@ -1,18 +1,18 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/showmodelslogic.go
View File

@ -6,13 +6,13 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/showservicelogic.go
View File

@ -6,13 +6,13 @@ package logic
*/
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"PCM/common/tool"
"context"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"k8s.io/apimachinery/pkg/util/json"
"net/http"

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/startnotebooklogic.go
View File

@ -1,19 +1,19 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic/stopnotebooklogic.go
View File

@ -1,19 +1,19 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"PCM/common/tool"
"bytes"
"context"
"encoding/json"
"fmt"
"github.com/JCCE-nudt/apigw-go-sdk/core"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"io/ioutil"
"net/http"
"strings"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/core/logx"
)

6
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/server/modelartsserver.go
View File

@ -6,9 +6,9 @@ package server
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
)
type ModelArtsServer struct {

4
adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc/servicecontext.go
View File

@ -1,10 +1,10 @@
package svc
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/config"
"PCM/adaptor/PCM-CORE/rpc/pcmcoreclient"
"github.com/robfig/cron/v3"
"github.com/zeromicro/go-zero/zrpc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/config"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-CORE/rpc/pcmcoreclient"
)
type ServiceContext struct {

8600
adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts/pcm-modelarts.pb.go
View File

File diff suppressed because it is too large Load Diff

90
adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts/pcm-modelarts_grpc.pb.go
View File

@ -1,7 +1,7 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc v3.19.4
// - protoc v4.22.2
// source: pcm-modelarts.proto
package modelarts
@ -65,39 +65,39 @@ const (
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type ModelArtsClient interface {
//get modelarts Token
// get modelarts Token
GetToken(ctx context.Context, in *TokenReq, opts ...grpc.CallOption) (*TokenResp, error)
//get modelarts Token
// get modelarts Token
GetDatasetList(ctx context.Context, in *DataSetReq, opts ...grpc.CallOption) (*DataSetResp, error)
//create DateSet
// create DateSet
CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error)
//create DateSet
// create DateSet
DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResq, error)
//creat task 创建导入任务
// creat task 创建导入任务
CreateTask(ctx context.Context, in *ImportTaskDataReq, opts ...grpc.CallOption) (*ImportTaskDataResp, error)
//get taskList 查询数据集导入任务列表
// get taskList 查询数据集导入任务列表
GetImportTaskList(ctx context.Context, in *ListImportTasksReq, opts ...grpc.CallOption) (*ListImportTasksResp, error)
// ListTrainingJobs 查询训练作业列表
// ListTrainingJobs 查询训练作业列表
GetListTrainingJobs(ctx context.Context, in *ListTrainingJobsreq, opts ...grpc.CallOption) (*ListTrainingJobsresp, error)
// CreateTrainingJob 创建训练作业
// CreateTrainingJob 创建训练作业
CreateTrainingJob(ctx context.Context, in *CreateTrainingJobReq, opts ...grpc.CallOption) (*CreateTrainingJobResp, error)
// DeleteTrainingJobConfig 删除训练作业
// DeleteTrainingJobConfig 删除训练作业
DeleteTrainingJob(ctx context.Context, in *DeleteTrainingJobReq, opts ...grpc.CallOption) (*DeleteTrainingJobResp, error)
// CreateTrainingJobConfig 创建训练作业参数
// CreateTrainingJobConfig 创建训练作业参数
CreateTrainingJobConfig(ctx context.Context, in *CreateTrainingJobConfigReq, opts ...grpc.CallOption) (*CreateTrainingJobConfigResp, error)
// DeleteTrainingJobConfig 删除训练作业参数
// DeleteTrainingJobConfig 删除训练作业参数
DeleteTrainingJobConfig(ctx context.Context, in *DeleteTrainingJobConfigReq, opts ...grpc.CallOption) (*DeleteTrainingJobConfigResp, error)
// ListTrainingJobConfig 查询训练作业参数
// ListTrainingJobConfig 查询训练作业参数
ListTrainingJobConfig(ctx context.Context, in *ListTrainingJobConfigReq, opts ...grpc.CallOption) (*ListTrainingJobConfigResp, error)
// CreateAlgorithm 创建算法
// CreateAlgorithm 创建算法
CreateAlgorithm(ctx context.Context, in *CreateAlgorithmReq, opts ...grpc.CallOption) (*CreateAlgorithmResp, error)
// ListAlgorithms 查询算法
// ListAlgorithms 查询算法
ListAlgorithms(ctx context.Context, in *ListAlgorithmsReq, opts ...grpc.CallOption) (*ListAlgorithmsResp, error)
// DeleteAlgorithms 删除算法
// DeleteAlgorithms 删除算法
DeleteAlgorithms(ctx context.Context, in *DeleteAlgorithmsReq, opts ...grpc.CallOption) (*DeleteAlgorithmsResp, error)
// ShowAlgorithmByUuid 展示算法详情
// ShowAlgorithmByUuid 展示算法详情
ShowAlgorithmByUuid(ctx context.Context, in *ShowAlgorithmByUuidReq, opts ...grpc.CallOption) (*ShowAlgorithmByUuidResp, error)
// training-job-flavors 获取训练作业支持的公共规格
// training-job-flavors 获取训练作业支持的公共规格
GetTrainingJobFlavors(ctx context.Context, in *TrainingJobFlavorsReq, opts ...grpc.CallOption) (*TrainingJobFlavorsResp, error)
// GET ai-engines 查询作业引擎规格
GetAiEnginesList(ctx context.Context, in *ListAiEnginesReq, opts ...grpc.CallOption) (*ListAiEnginesResp, error)
@ -105,28 +105,28 @@ type ModelArtsClient interface {
ExportTask(ctx context.Context, in *ExportTaskReq, opts ...grpc.CallOption) (*ExportTaskDataResp, error)
GetExportTasksOfDataset(ctx context.Context, in *GetExportTasksOfDatasetReq, opts ...grpc.CallOption) (*GetExportTasksOfDatasetResp, error)
GetExportTaskStatusOfDataset(ctx context.Context, in *GetExportTaskStatusOfDatasetReq, opts ...grpc.CallOption) (*GetExportTaskStatusOfDatasetResp, error)
//processor task
// processor task
CreateProcessorTask(ctx context.Context, in *CreateProcessorTaskReq, opts ...grpc.CallOption) (*CreateProcessorTaskResp, error)
DescribeProcessorTask(ctx context.Context, in *DescribeProcessorTaskReq, opts ...grpc.CallOption) (*DescribeProcessorTaskResp, error)
//model management
// model management
CreateModel(ctx context.Context, in *CreateModelReq, opts ...grpc.CallOption) (*CreateModelResp, error)
DeleteModel(ctx context.Context, in *DeleteModelReq, opts ...grpc.CallOption) (*DeleteModelResp, error)
ListModels(ctx context.Context, in *ListModelReq, opts ...grpc.CallOption) (*ListModelResp, error)
ShowModels(ctx context.Context, in *ShowModelReq, opts ...grpc.CallOption) (*ShowModelResp, error)
//service management
// service management
CreateService(ctx context.Context, in *CreateServiceReq, opts ...grpc.CallOption) (*CreateServiceResp, error)
ListServices(ctx context.Context, in *ListServicesReq, opts ...grpc.CallOption) (*ListServicesResp, error)
ShowService(ctx context.Context, in *ShowServiceReq, opts ...grpc.CallOption) (*ShowServiceResp, error)
DeleteService(ctx context.Context, in *DeleteServiceReq, opts ...grpc.CallOption) (*DeleteServiceResp, error)
ListClusters(ctx context.Context, in *ListClustersReq, opts ...grpc.CallOption) (*ListClustersResp, error)
//notebook task
// notebook task
ListNotebook(ctx context.Context, in *ListNotebookReq, opts ...grpc.CallOption) (*ListNotebookResp, error)
CreateNotebook(ctx context.Context, in *CreateNotebookReq, opts ...grpc.CallOption) (*CreateNotebookResp, error)
StartNotebook(ctx context.Context, in *StartNotebookReq, opts ...grpc.CallOption) (*StartNotebookResp, error)
StopNotebook(ctx context.Context, in *StopNotebookReq, opts ...grpc.CallOption) (*StopNotebookResp, error)
GetNotebookStorage(ctx context.Context, in *GetNotebookStorageReq, opts ...grpc.CallOption) (*GetNotebookStorageResp, error)
MountNotebookStorage(ctx context.Context, in *MountNotebookStorageReq, opts ...grpc.CallOption) (*MountNotebookStorageResp, error)
//visualization-jobs
// visualization-jobs
GetVisualizationJob(ctx context.Context, in *GetVisualizationJobReq, opts ...grpc.CallOption) (*GetVisualizationJobResp, error)
CreateVisualizationJob(ctx context.Context, in *CreateVisualizationJobReq, opts ...grpc.CallOption) (*CreateVisualizationJobResp, error)
}
@ -503,39 +503,39 @@ func (c *modelArtsClient) CreateVisualizationJob(ctx context.Context, in *Create
// All implementations must embed UnimplementedModelArtsServer
// for forward compatibility
type ModelArtsServer interface {
//get modelarts Token
// get modelarts Token
GetToken(context.Context, *TokenReq) (*TokenResp, error)
//get modelarts Token
// get modelarts Token
GetDatasetList(context.Context, *DataSetReq) (*DataSetResp, error)
//create DateSet
// create DateSet
CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResq, error)
//create DateSet
// create DateSet
DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResq, error)
//creat task 创建导入任务
// creat task 创建导入任务
CreateTask(context.Context, *ImportTaskDataReq) (*ImportTaskDataResp, error)
//get taskList 查询数据集导入任务列表
// get taskList 查询数据集导入任务列表
GetImportTaskList(context.Context, *ListImportTasksReq) (*ListImportTasksResp, error)
// ListTrainingJobs 查询训练作业列表
// ListTrainingJobs 查询训练作业列表
GetListTrainingJobs(context.Context, *ListTrainingJobsreq) (*ListTrainingJobsresp, error)
// CreateTrainingJob 创建训练作业
// CreateTrainingJob 创建训练作业
CreateTrainingJob(context.Context, *CreateTrainingJobReq) (*CreateTrainingJobResp, error)
// DeleteTrainingJobConfig 删除训练作业
// DeleteTrainingJobConfig 删除训练作业
DeleteTrainingJob(context.Context, *DeleteTrainingJobReq) (*DeleteTrainingJobResp, error)
// CreateTrainingJobConfig 创建训练作业参数
// CreateTrainingJobConfig 创建训练作业参数
CreateTrainingJobConfig(context.Context, *CreateTrainingJobConfigReq) (*CreateTrainingJobConfigResp, error)
// DeleteTrainingJobConfig 删除训练作业参数
// DeleteTrainingJobConfig 删除训练作业参数
DeleteTrainingJobConfig(context.Context, *DeleteTrainingJobConfigReq) (*DeleteTrainingJobConfigResp, error)
// ListTrainingJobConfig 查询训练作业参数
// ListTrainingJobConfig 查询训练作业参数
ListTrainingJobConfig(context.Context, *ListTrainingJobConfigReq) (*ListTrainingJobConfigResp, error)
// CreateAlgorithm 创建算法
// CreateAlgorithm 创建算法
CreateAlgorithm(context.Context, *CreateAlgorithmReq) (*CreateAlgorithmResp, error)
// ListAlgorithms 查询算法
// ListAlgorithms 查询算法
ListAlgorithms(context.Context, *ListAlgorithmsReq) (*ListAlgorithmsResp, error)
// DeleteAlgorithms 删除算法
// DeleteAlgorithms 删除算法
DeleteAlgorithms(context.Context, *DeleteAlgorithmsReq) (*DeleteAlgorithmsResp, error)
// ShowAlgorithmByUuid 展示算法详情
// ShowAlgorithmByUuid 展示算法详情
ShowAlgorithmByUuid(context.Context, *ShowAlgorithmByUuidReq) (*ShowAlgorithmByUuidResp, error)
// training-job-flavors 获取训练作业支持的公共规格
// training-job-flavors 获取训练作业支持的公共规格
GetTrainingJobFlavors(context.Context, *TrainingJobFlavorsReq) (*TrainingJobFlavorsResp, error)
// GET ai-engines 查询作业引擎规格
GetAiEnginesList(context.Context, *ListAiEnginesReq) (*ListAiEnginesResp, error)
@ -543,28 +543,28 @@ type ModelArtsServer interface {
ExportTask(context.Context, *ExportTaskReq) (*ExportTaskDataResp, error)
GetExportTasksOfDataset(context.Context, *GetExportTasksOfDatasetReq) (*GetExportTasksOfDatasetResp, error)
GetExportTaskStatusOfDataset(context.Context, *GetExportTaskStatusOfDatasetReq) (*GetExportTaskStatusOfDatasetResp, error)
//processor task
// processor task
CreateProcessorTask(context.Context, *CreateProcessorTaskReq) (*CreateProcessorTaskResp, error)
DescribeProcessorTask(context.Context, *DescribeProcessorTaskReq) (*DescribeProcessorTaskResp, error)
//model management
// model management
CreateModel(context.Context, *CreateModelReq) (*CreateModelResp, error)
DeleteModel(context.Context, *DeleteModelReq) (*DeleteModelResp, error)
ListModels(context.Context, *ListModelReq) (*ListModelResp, error)
ShowModels(context.Context, *ShowModelReq) (*ShowModelResp, error)
//service management
// service management
CreateService(context.Context, *CreateServiceReq) (*CreateServiceResp, error)
ListServices(context.Context, *ListServicesReq) (*ListServicesResp, error)
ShowService(context.Context, *ShowServiceReq) (*ShowServiceResp, error)
DeleteService(context.Context, *DeleteServiceReq) (*DeleteServiceResp, error)
ListClusters(context.Context, *ListClustersReq) (*ListClustersResp, error)
//notebook task
// notebook task
ListNotebook(context.Context, *ListNotebookReq) (*ListNotebookResp, error)
CreateNotebook(context.Context, *CreateNotebookReq) (*CreateNotebookResp, error)
StartNotebook(context.Context, *StartNotebookReq) (*StartNotebookResp, error)
StopNotebook(context.Context, *StopNotebookReq) (*StopNotebookResp, error)
GetNotebookStorage(context.Context, *GetNotebookStorageReq) (*GetNotebookStorageResp, error)
MountNotebookStorage(context.Context, *MountNotebookStorageReq) (*MountNotebookStorageResp, error)
//visualization-jobs
// visualization-jobs
GetVisualizationJob(context.Context, *GetVisualizationJobReq) (*GetVisualizationJobResp, error)
CreateVisualizationJob(context.Context, *CreateVisualizationJobReq) (*CreateVisualizationJobResp, error)
mustEmbedUnimplementedModelArtsServer()

8
adaptor/PCM-AI/PCM-MODELARTS/rpc/modelartsclient/modelarts.go
View File

@ -6,7 +6,7 @@ package modelartsclient
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
"github.com/zeromicro/go-zero/zrpc"
"google.golang.org/grpc"
@ -71,6 +71,7 @@ type (
DataSources = modelarts.DataSources
DataVolumesRes = modelarts.DataVolumesRes
Dataset = modelarts.Dataset
DatasetTra = modelarts.DatasetTra
DeleteAlgorithmsReq = modelarts.DeleteAlgorithmsReq
DeleteAlgorithmsResp = modelarts.DeleteAlgorithmsResp
DeleteDataSetReq = modelarts.DeleteDataSetReq
@ -125,6 +126,7 @@ type (
ImportTasks = modelarts.ImportTasks
Input = modelarts.Input
InputDataInfo = modelarts.InputDataInfo
InputTraining = modelarts.InputTraining
Inputs = modelarts.Inputs
InputsAlRp = modelarts.InputsAlRp
InputsAlRq = modelarts.InputsAlRq
@ -182,8 +184,10 @@ type (
Npu = modelarts.Npu
Obs = modelarts.Obs
Obs1 = modelarts.Obs1
ObsTra = modelarts.ObsTra
OperatorParam = modelarts.OperatorParam
Output = modelarts.Output
OutputTraining = modelarts.OutputTraining
Outputs = modelarts.Outputs
OutputsAl = modelarts.OutputsAl
OutputsAlRp = modelarts.OutputsAlRp
@ -205,6 +209,8 @@ type (
Remote = modelarts.Remote
RemoteConstraint = modelarts.RemoteConstraint
RemoteConstraints = modelarts.RemoteConstraints
RemoteOut = modelarts.RemoteOut
RemoteTra = modelarts.RemoteTra
Resource = modelarts.Resource
ResourceCreateTraining = modelarts.ResourceCreateTraining
ResourceRequirements = modelarts.ResourceRequirements

14
adaptor/PCM-AI/PCM-MODELARTS/rpc/pcmmodelarts.go
View File

@ -1,18 +1,18 @@
package main
import (
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/config"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/server"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
commonConfig "PCM/common/config"
"PCM/common/interceptor/rpcserver"
"flag"
"github.com/zeromicro/go-zero/core/conf"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/service"
"github.com/zeromicro/go-zero/zrpc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/config"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/logic"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/server"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts"
commonConfig "gitlink.org.cn/JCCE/PCM.git/common/config"
"gitlink.org.cn/JCCE/PCM.git/common/interceptor/rpcserver"
"google.golang.org/grpc"
"google.golang.org/grpc/reflection"
)

2
adaptor/PCM-AI/PCM-MS/rpc/agentservice/agentservice.go
View File

@ -6,7 +6,7 @@ package agentservice
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/ms"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/ms"
"github.com/zeromicro/go-zero/zrpc"
"google.golang.org/grpc"

4
adaptor/PCM-AI/PCM-MS/rpc/internal/logic/changeclusterstatelogic.go
View File

@ -3,8 +3,8 @@ package logic
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/ms"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/ms"
"github.com/zeromicro/go-zero/core/logx"
)

4
adaptor/PCM-AI/PCM-MS/rpc/internal/logic/registeracklogic.go
View File

@ -3,8 +3,8 @@ package logic
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/ms"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/ms"
"github.com/zeromicro/go-zero/core/logx"
)

4
adaptor/PCM-AI/PCM-MS/rpc/internal/logic/requirereregisterlogic.go
View File

@ -3,8 +3,8 @@ package logic
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/ms"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/ms"
"github.com/zeromicro/go-zero/core/logx"
)

6
adaptor/PCM-AI/PCM-MS/rpc/internal/server/agentserviceserver.go
View File

@ -6,9 +6,9 @@ package server
import (
"context"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/logic"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/ms"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/logic"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/ms"
)
type AgentServiceServer struct {

2
adaptor/PCM-AI/PCM-MS/rpc/internal/svc/servicecontext.go
View File

@ -1,6 +1,6 @@
package svc
import "PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/config"
import "gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/config"
type ServiceContext struct {
Config config.Config

8
adaptor/PCM-AI/PCM-MS/rpc/pcmms.go
View File

@ -4,10 +4,10 @@ import (
"flag"
"fmt"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/config"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/server"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-MS/rpc/ms"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/config"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/server"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-MS/rpc/ms"
"github.com/zeromicro/go-zero/core/conf"
"github.com/zeromicro/go-zero/core/service"

2
adaptor/PCM-AI/PCM-OCTOPUS/rpc/etc/octopus.yaml
View File

@ -7,7 +7,7 @@ NacosConfig:
# - IpAddr: nacos-headless
# Port: 8848
ClientConfig:
NamespaceId: test_octopus
NamespaceId: zhouqj
TimeoutMs: 5000
NotLoadCacheAtStart: true
LogDir:

20
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common/tokenService.go
View File

@ -1,10 +1,10 @@
package common
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config"
"PCM/common/tool"
"bytes"
"encoding/json"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"time"
)
@ -40,6 +40,9 @@ func generateTokenMap() map[string]TokenTimePair {
}
for k, v := range urlMap {
token, expiredAt := generateToken(jsonStr, v)
if token == "" {
continue
}
tokenTimePair := TokenTimePair{
Token: token,
ExpiredAt: expiredAt,
@ -67,18 +70,21 @@ func generateToken(jsonStr []byte, tokenUrl string) (string, time.Time) {
func GetToken(kForToken string) string {
if tokenMap[kForToken].Token == "" {
tokenMap = generateTokenMap()
return ""
}
tokenTimePair := tokenMap[kForToken]
if tokenTimePair.Token == "" {
return ""
}
if time.Now().After(tokenTimePair.ExpiredAt) {
tokenMap = generateTokenMap()
if tokenMap[kForToken].Token == "" {
return ""
} else {
return tokenMap[kForToken].Token
}
}
return tokenTimePair.Token
}

2
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/config.go
View File

@ -1,12 +1,12 @@
package config
import (
commonConfig "PCM/common/config"
"flag"
"github.com/zeromicro/go-zero/core/conf"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/stores/redis"
"github.com/zeromicro/go-zero/zrpc"
commonConfig "gitlink.org.cn/JCCE/PCM.git/common/config"
)
type Config struct {

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createdatasetlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
)
type CreateDataSetLogic struct {
@ -30,6 +32,10 @@ func (l *CreateDataSetLogic) CreateDataSet(in *octopus.CreateDataSetReq) (*octop
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateDataSet
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createdatasetversionlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *CreateDataSetVersionLogic) CreateDataSetVersion(in *octopus.CreateDataS
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateDataSetVersion
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createimagelogic.go
View File

@ -1,11 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"github.com/zeromicro/go-zero/core/logx"
)
@ -31,6 +33,10 @@ func (l *CreateImageLogic) CreateImage(in *octopus.CreateImageReq) (*octopus.Cre
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateImage
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createmodeldeploylogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *CreateModelDeployLogic) CreateModelDeploy(in *octopus.CreateModelDeploy
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateModelDeploy
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createmyalgorithmlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *CreateMyAlgorithmLogic) CreateMyAlgorithm(in *octopus.CreateMyAlgorithm
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateMyAlgorithm
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createnotebooklogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *CreateNotebookLogic) CreateNotebook(in *octopus.CreateNotebookReq) (*oc
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateNotebook
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createtrainjoblogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *CreateTrainJobLogic) CreateTrainJob(in *octopus.CreateTrainJobReq) (*oc
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateTrainJob
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletedatasetlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteDataSetLogic) DeleteDataSet(in *octopus.DeleteDataSetReq) (*octop
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteDataSet
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletedatasetversionlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteDataSetVersionLogic) DeleteDataSetVersion(in *octopus.DeleteDataS
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteDataSetVersion
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deleteimagelogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteImageLogic) DeleteImage(in *octopus.DeleteImageReq) (*octopus.Del
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteImage
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletemodeldeploylogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteModelDeployLogic) DeleteModelDeploy(in *octopus.DeleteModelDeploy
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteModelDeploy
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
var queryStr string
for _, s := range in.GetJobIds() {

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletemodelversionlogic.go
View File

@ -1,11 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"github.com/zeromicro/go-zero/core/logx"
)
@ -31,6 +33,10 @@ func (l *DeleteModelVersionLogic) DeleteModelVersion(in *octopus.DeleteModelVers
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteModelVersion
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletemyalgorithmlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteMyAlgorithmLogic) DeleteMyAlgorithm(in *octopus.DeleteMyAlgorithm
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteMyAlgorithm
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletemymodellogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteMyModelLogic) DeleteMyModel(in *octopus.DeleteMyModelReq) (*octop
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteMyModel
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletenotebooklogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DeleteNotebookLogic) DeleteNotebook(in *octopus.DeleteNotebookReq) (*oc
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteNotebook
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

15
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletetrainjoblogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,11 @@ func (l *DeleteTrainJobLogic) DeleteTrainJob(in *octopus.DeleteTrainJobReq) (*oc
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteTrainJob
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
var queryStr string

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/downloadalgorithmlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *DownloadAlgorithmLogic) DownloadAlgorithm(in *octopus.DownloadAlgorithm
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DownloadAlgorithm
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/downloadmodelversionlogic.go
View File

@ -1,11 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"github.com/zeromicro/go-zero/core/logx"
)
@ -31,6 +33,10 @@ func (l *DownloadModelVersionLogic) DownloadModelVersion(in *octopus.DownloadMod
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DownloadModelVersion
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmapplylistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetAlgorithmApplyListLogic) GetAlgorithmApplyList(in *octopus.GetAlgori
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithmApplyList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmframeworklistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetAlgorithmFrameworkListLogic) GetAlgorithmFrameworkList(in *octopus.G
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithmFrameworkList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmlistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetAlgorithmListLogic) GetAlgorithmList(in *octopus.GetAlgorithmListReq
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithmList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmlogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *GetAlgorithmLogic) GetAlgorithm(in *octopus.GetAlgorithmReq) (*octopus.
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithm
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

11
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getcomputingpowerlogic.go
View File

@ -1,14 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"context"
"encoding/json"
"github.com/go-redis/redis"
"github.com/zeromicro/go-zero/core/logx"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"log"
"strconv"
"time"
@ -70,6 +70,9 @@ func getCPFromOctopus() float32 {
var computingPowerInTops int32
for k, v := range urlMap {
token := common.GetToken(k)
if token == "" {
continue
}
body, err := common.OctopusHttpClient("GET", v, nil, token)
if err != nil {
continue

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getdatasetapplylistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetDatasetApplyListLogic) GetDatasetApplyList(in *octopus.GetDatasetApp
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetDatasetApplyList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getdatasettypelistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetDatasetTypeListLogic) GetDatasetTypeList(in *octopus.GetDatasetTypeL
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetDatasetTypeList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getdatasetversionlistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetDatasetVersionListLogic) GetDatasetVersionList(in *octopus.GetDatase
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetDatasetVersionList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

11
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getgeneralinfologic.go
View File

@ -1,18 +1,18 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config"
"context"
"encoding/json"
"github.com/go-redis/redis"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config"
"log"
"strconv"
"strings"
"time"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -89,6 +89,9 @@ func getGeneralInfoFromOctopus() (int32, int32) {
var memoryInGib int32
for k, v := range urlMap {
token := common.GetToken(k)
if token == "" {
continue
}
body, err := common.OctopusHttpClient("GET", v, nil, token)
if err != nil {
continue

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmodeldeployeventlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetModelDeployEventLogic) GetModelDeployEvent(in *octopus.GetModelDeplo
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetModelDeployEvent
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmodeldeploylistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetModelDeployListLogic) GetModelDeployList(in *octopus.GetModelDeployL
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetModelDeployList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmodeldeploylogic.go
View File

@ -1,11 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"github.com/zeromicro/go-zero/core/logx"
)
@ -31,6 +33,10 @@ func (l *GetModelDeployLogic) GetModelDeploy(in *octopus.GetModelDeployReq) (*oc
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetModelDeploy
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmodelversionlistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetModelVersionListLogic) GetModelVersionList(in *octopus.GetModelVersi
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetModelVersionList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmyalgorithmlistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -34,6 +36,10 @@ func (l *GetMyAlgorithmListLogic) GetMyAlgorithmList(in *octopus.GetMyAlgorithmL
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetMyAlgorithmList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmydatasetlistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -34,6 +36,10 @@ func (l *GetMyDatasetListLogic) GetMyDatasetList(in *octopus.GetMyDatasetListReq
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetMydatasetList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getmymodellistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -34,6 +36,10 @@ func (l *GetMyModelListLogic) GetMyModelList(in *octopus.GetMyModelListReq) (*oc
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetMyModelList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getnotebooklistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -34,6 +36,10 @@ func (l *GetNotebookListLogic) GetNotebookList(in *octopus.GetNotebookListReq) (
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetNotebookList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getnotebooklogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *GetNotebookLogic) GetNotebook(in *octopus.GetNotebookReq) (*octopus.Get
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetNotebook
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/gettrainjobeventlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetTrainJobEventLogic) GetTrainJobEvent(in *octopus.GetTrainJobEventReq
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetTrainJobEvent
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/gettrainjoblistlogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetTrainJobListLogic) GetTrainJobList(in *octopus.GetTrainJobListReq) (
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetTrainJobList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/gettrainjoblogic.go
View File

@ -1,11 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"github.com/zeromicro/go-zero/core/logx"
)
@ -31,6 +33,10 @@ func (l *GetTrainJobLogic) GetTrainJob(in *octopus.GetTrainJobReq) (*octopus.Get
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetTrainJob
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/gettrainjobmetriclogic.go
View File

@ -1,13 +1,15 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -33,6 +35,10 @@ func (l *GetTrainJobMetricLogic) GetTrainJobMetric(in *octopus.GetTrainJobMetric
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetTrainJobMetric
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getuserimagelistlogic.go
View File

@ -1,11 +1,13 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"strconv"
"github.com/zeromicro/go-zero/core/logx"
@ -33,6 +35,10 @@ func (l *GetUserImageListLogic) GetUserImageList(in *octopus.GetUserImageListReq
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetUserImageList
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

14
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/infermodeldeploylogic.go
View File

@ -1,12 +1,14 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"errors"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"gitlink.org.cn/JCCE/PCM.git/common/tool"
"log"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"gitlink.org.cn/JCCE/PCM.git/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
@ -32,6 +34,10 @@ func (l *InferModelDeployLogic) InferModelDeploy(in *octopus.InferModelDeployReq
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.InferModelDeploy
token := common.GetToken(in.Platform)
if token == "" {
log.Println("获取token失败, platform : ", in.Platform)
return nil, errors.New("获取token失败")
}
req := tool.GetACHttpRequest()
_, err := req.

Some files were not shown because too many files have changed in this diff Show More