超算接入specfem3d_globe app

This commit is contained in:
chenpeng0206 2026-03-06 11:12:24 +08:00
parent dda76fbe97
commit 4a4c000108
1 changed files with 3 additions and 3 deletions

View File

@ -122,7 +122,7 @@ public class CSCollectServiceImpl implements CSCollectService {
CSAuthInfo csAuthInfo = getZSAuthInfoFromRedis();
List<Map<String, Object>> hpcBindingFiles = buildHpcBindingFiles(taskParam, taskInfo);
JSONObject params = convertToJobRequest(clusterId, jobName, hpcBindingFiles, csAuthInfo.getUserId(), ntasks, nodes);
JSONObject params = convertToJobRequest(trainingTask.getTaskName(),clusterId, jobName, hpcBindingFiles, csAuthInfo.getUserId(), ntasks, nodes);
String url = csUrl + "/jsm/v2/jobs/submit";
String res = HttpUtils.sendBodyPostWithToken(url, params, csAuthInfo.getToken());
@ -215,7 +215,7 @@ public class CSCollectServiceImpl implements CSCollectService {
* @param nodes 节点数
* @return 符合JSON串3结构的JSONObject
*/
public JSONObject convertToJobRequest(String clusterId, String name,
public JSONObject convertToJobRequest(String taskName,String clusterId, String name,
List<Map<String, Object>> hpcBindingFiles,
Integer userId, String ntasks, String nodes) {
// 根对象
@ -233,7 +233,7 @@ public class CSCollectServiceImpl implements CSCollectService {
hpcJob.set("name", name);
hpcJob.set("clusterId", clusterId);
hpcJob.set("backend", "slurm");
hpcJob.set("app", "specfem3d_globe");
hpcJob.set("app", taskName);
hpcJob.set("operateType", "");
// parameters 对象