Browse Source

换回原来的HTTPUTILS

dev-DXTZYK
fanshuai 1 year ago
parent
commit
db3ce4581d
1 changed files with 3 additions and 4 deletions
  1. +3
    -4
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentServiceImpl.java

+ 3
- 4
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentServiceImpl.java View File

@@ -8,6 +8,7 @@ import com.ruoyi.platform.domain.dependencydomain.TrainTaskDepency;
import com.ruoyi.platform.mapper.ExperimentDao; import com.ruoyi.platform.mapper.ExperimentDao;
import com.ruoyi.platform.mapper.ExperimentInsDao; import com.ruoyi.platform.mapper.ExperimentInsDao;
import com.ruoyi.platform.service.*; import com.ruoyi.platform.service.*;
import com.ruoyi.platform.utils.HttpUtils;
import com.ruoyi.platform.utils.JacksonUtil; import com.ruoyi.platform.utils.JacksonUtil;
import com.ruoyi.platform.utils.JsonUtils; import com.ruoyi.platform.utils.JsonUtils;
import com.ruoyi.platform.utils.NewHttpUtils; import com.ruoyi.platform.utils.NewHttpUtils;
@@ -55,8 +56,6 @@ public class ExperimentServiceImpl implements ExperimentService {
@Resource @Resource
@Lazy @Lazy
private ExperimentInsService experimentInsService; private ExperimentInsService experimentInsService;
@Resource
private NewHttpUtils httpUtils;
@Value("${argo.url}") @Value("${argo.url}")
private String argoUrl; private String argoUrl;
@Value("${argo.convert}") @Value("${argo.convert}")
@@ -223,7 +222,7 @@ public class ExperimentServiceImpl implements ExperimentService {
String dag = workflow.getDag(); String dag = workflow.getDag();
// 调argo转换接口 // 调argo转换接口
try { try {
String convertRes = httpUtils.sendPost(argoUrl + argoConvert,null, dag);
String convertRes = HttpUtils.sendPost(argoUrl + argoConvert, dag);
if (convertRes == null || StringUtils.isEmpty(convertRes)) { if (convertRes == null || StringUtils.isEmpty(convertRes)) {
throw new RuntimeException("转换流水线失败"); throw new RuntimeException("转换流水线失败");
} }
@@ -242,7 +241,7 @@ public class ExperimentServiceImpl implements ExperimentService {


Map<String ,Object> output = (Map<String, Object>) converMap.get("output"); Map<String ,Object> output = (Map<String, Object>) converMap.get("output");
// 调argo运行接口 // 调argo运行接口
String runRes = httpUtils.sendPost(argoUrl + argoWorkflowRun,null, JsonUtils.mapToJson(runReqMap));
String runRes = HttpUtils.sendPost(argoUrl + argoWorkflowRun, JsonUtils.mapToJson(runReqMap));


if (runRes == null || StringUtils.isEmpty(runRes)) { if (runRes == null || StringUtils.isEmpty(runRes)) {
throw new RuntimeException("Failed to run workflow."); throw new RuntimeException("Failed to run workflow.");


Loading…
Cancel
Save