| @@ -157,6 +157,11 @@ public class ActiveLearnServiceImpl implements ActiveLearnService { | |||||
| throw new RuntimeException("转换流水线失败"); | throw new RuntimeException("转换流水线失败"); | ||||
| } | } | ||||
| Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | ||||
| String convertResData = (String) converMap.get("data"); | |||||
| if (StringUtils.isEmpty(convertResData)) { | |||||
| throw new RuntimeException("转换流水线失败"); | |||||
| } | |||||
| // 组装运行接口json | // 组装运行接口json | ||||
| Map<String, Object> output = (Map<String, Object>) converMap.get("output"); | Map<String, Object> output = (Map<String, Object>) converMap.get("output"); | ||||
| Map<String, Object> runReqMap = new HashMap<>(); | Map<String, Object> runReqMap = new HashMap<>(); | ||||
| @@ -237,6 +237,10 @@ public class ExperimentServiceImpl implements ExperimentService { | |||||
| throw new Exception("转换流水线失败"); | throw new Exception("转换流水线失败"); | ||||
| } | } | ||||
| Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | ||||
| String convertResData = (String) converMap.get("data"); | |||||
| if (StringUtils.isEmpty(convertResData)) { | |||||
| throw new RuntimeException("转换流水线失败"); | |||||
| } | |||||
| // 判断积分和资源是否足够 | // 判断积分和资源是否足够 | ||||
| Map<String, Map<String, Object>> resourceInfo = (Map<String, Map<String, Object>>) converMap.get("resource_info"); | Map<String, Map<String, Object>> resourceInfo = (Map<String, Map<String, Object>>) converMap.get("resource_info"); | ||||
| @@ -165,6 +165,13 @@ public class MachineLearnServiceImpl implements MachineLearnService { | |||||
| if (convertRes == null || StringUtils.isEmpty(convertRes)) { | if (convertRes == null || StringUtils.isEmpty(convertRes)) { | ||||
| throw new RuntimeException("转换流水线失败"); | throw new RuntimeException("转换流水线失败"); | ||||
| } | } | ||||
| Map<String, Object> convertResMap = JsonUtils.jsonToMap(convertRes); | |||||
| String convertResData = (String) convertResMap.get("data"); | |||||
| if (StringUtils.isEmpty(convertResData)) { | |||||
| throw new RuntimeException("转换流水线失败"); | |||||
| } | |||||
| Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | ||||
| // 组装运行接口json | // 组装运行接口json | ||||
| Map<String, Object> output = (Map<String, Object>) converMap.get("output"); | Map<String, Object> output = (Map<String, Object>) converMap.get("output"); | ||||
| @@ -175,7 +175,13 @@ public class RayServiceImpl implements RayService { | |||||
| if (convertRes == null || StringUtils.isEmpty(convertRes)) { | if (convertRes == null || StringUtils.isEmpty(convertRes)) { | ||||
| throw new RuntimeException("转换流水线失败"); | throw new RuntimeException("转换流水线失败"); | ||||
| } | } | ||||
| Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | Map<String, Object> converMap = JsonUtils.jsonToMap(convertRes); | ||||
| String convertResData = (String) converMap.get("data"); | |||||
| if (StringUtils.isEmpty(convertResData)) { | |||||
| throw new RuntimeException("转换流水线失败"); | |||||
| } | |||||
| // 组装运行接口json | // 组装运行接口json | ||||
| Map<String, Object> output = (Map<String, Object>) converMap.get("output"); | Map<String, Object> output = (Map<String, Object>) converMap.get("output"); | ||||
| Map<String, Object> runReqMap = new HashMap<>(); | Map<String, Object> runReqMap = new HashMap<>(); | ||||