|
|
|
@@ -312,9 +312,7 @@ func GrampusTrainJobNpuCreate(ctx *context.Context, form auth.CreateGrampusTrain |
|
|
|
} |
|
|
|
|
|
|
|
//prepare command |
|
|
|
//todo: download code, download dataset, unzip dataset, exec code, upload model |
|
|
|
command, err := generateCommand(repo.Name, grampus.ProcessorTypeNPU, codeObsPath+cloudbrain.DefaultBranchName+".zip", dataObsPath+attachment.Name, bootFile, params, setting.CodePathPrefix+jobName+modelarts.OutputPath, attachment.Name) |
|
|
|
log.Info(command) |
|
|
|
|
|
|
|
commitID, _ := ctx.Repo.GitRepo.GetBranchCommitID(branchName) |
|
|
|
|
|
|
|
@@ -550,7 +548,12 @@ func generateCommand(repoName, processorType, codeObsPath, dataObsPath, bootFile |
|
|
|
} |
|
|
|
|
|
|
|
//unzip code & dataset |
|
|
|
commandUnzip := "cd /tmp/dataset;unzip " + datasetName + ";cd /tmp/code;unzip master.zip;" |
|
|
|
toolUnzip := "unzip -q " |
|
|
|
if strings.HasSuffix(datasetName, ".tar.gz") { |
|
|
|
toolUnzip = "tar -zxvf " |
|
|
|
} |
|
|
|
commandUnzip := "cd /tmp/dataset;" + toolUnzip + datasetName + ";cd /tmp/code;unzip -q master.zip;" |
|
|
|
commandUnzip += "cd /tmp/dataset/" + strings.TrimSuffix(datasetName, ".zip") + ";ls;" |
|
|
|
command += commandUnzip |
|
|
|
|
|
|
|
//exec code |
|
|
|
@@ -573,7 +576,7 @@ func generateCommand(repoName, processorType, codeObsPath, dataObsPath, bootFile |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
commandCode := "cd " + repoName + ";python " + bootFile + paramCode + ";" |
|
|
|
commandCode := "cd /tmp/code/" + repoName + ";python " + bootFile + paramCode + ";" |
|
|
|
command += commandCode |
|
|
|
|
|
|
|
//upload models |
|
|
|
|