|
|
|
@@ -32,6 +32,8 @@ public class RayInsServiceImpl implements RayInsService { |
|
|
|
private String argoWorkflowStatus; |
|
|
|
@Value("${argo.workflowTermination}") |
|
|
|
private String argoWorkflowTermination; |
|
|
|
@Value("${minio.endpoint}") |
|
|
|
String endpoint; |
|
|
|
@Value("${minio.dataReleaseBucketName}") |
|
|
|
private String bucketName; |
|
|
|
|
|
|
|
@@ -270,6 +272,10 @@ public class RayInsServiceImpl implements RayInsService { |
|
|
|
public void getTrialList(RayIns rayIns) throws Exception { |
|
|
|
// 获取指定路径下的所有文件 |
|
|
|
String directoryPath = rayIns.getResultPath(); |
|
|
|
|
|
|
|
rayIns.setResultPath(endpoint + "/" + directoryPath); |
|
|
|
rayIns.setResultTxt(endpoint + "/" + directoryPath + "/result.txt"); |
|
|
|
|
|
|
|
String prefix = directoryPath.substring(directoryPath.indexOf("/") + 1, directoryPath.length()) + "/"; |
|
|
|
List<Map> maps = minioUtil.listFilesInDirectory(bucketName, prefix); |
|
|
|
|
|
|
|
|