换回原来的HTTPUTILS
This commit is contained in:
parent
39f7b05869
commit
db3ce4581d
|
@ -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…
Reference in New Issue