zhangweiii
/
pcm-coordinator
forked from JointCloud/pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

超算任务提交参数修改

This commit is contained in:
zhangwei 2024-11-25 10:54:41 +08:00
parent 0005bfcd07
commit 1a59690f2e
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/logic/cloud/getclusterlistlogic.go
View File

@ -24,7 +24,6 @@ func NewGetClusterListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Ge
func (l *GetClusterListLogic) GetClusterList(req *types.GetClusterListReq) (resp *types.GetClusterListResp, err error) { func (l *GetClusterListLogic) GetClusterList(req *types.GetClusterListReq) (resp *types.GetClusterListResp, err error) {
resp = &types.GetClusterListResp{} resp = &types.GetClusterListResp{}
//clusters := []models.ScParticipantPhyInfo{}
l.svcCtx.DbEngin.Raw("select * from t_cluster where adapter_id = ?", req.AdapterId).Scan(&resp.Clusters) l.svcCtx.DbEngin.Raw("select * from t_cluster where adapter_id = ?", req.AdapterId).Scan(&resp.Clusters)
return resp, nil return resp, nil
} }

4
internal/logic/hpc/commithpctasklogic.go
View File

@ -136,8 +136,8 @@ func submitJob(hpcInfo *models.TaskHpc, clusterInfo *types.ClusterInfo, adapterA
Partition: hpcInfo.Partition, Partition: hpcInfo.Partition,
Environment: map[string]string{"PATH": clusterInfo.EnvPath, Environment: map[string]string{"PATH": clusterInfo.EnvPath,
"LD_LIBRARY_PATH": clusterInfo.EnvLdPath}, "LD_LIBRARY_PATH": clusterInfo.EnvLdPath},
StandardOutput: hpcInfo.WorkDir + "/%j.out", StandardOutput: hpcInfo.WorkDir + "/job.out",
StandardError: hpcInfo.WorkDir + "/%j.err", StandardError: hpcInfo.WorkDir + "/job.err",
}, },
}, },
} }