Skip to content

B
byit-myth-job
Commit 13c7c41d by huangfusuper
Options

数据质检开始 基于多个runId

parent a7aa4ce1
Showing with 2 additions and 2 deletions
byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java
...@@ -1532,8 +1532,8 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -1532,8 +1532,8 @@ public class ApiFlowServiceImpl implements ApiFlowService {
List<RunRecording> runRecordings = runRecordingMapper.runIngRunRecording(flowName, byName.getWorkspaceId()); List<RunRecording> runRecordings = runRecordingMapper.runIngRunRecording(flowName, byName.getWorkspaceId());
ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(runRecordings), "没有正在运行中的实例！"); ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(runRecordings), "没有正在运行中的实例！");
List<RunRecording> collect = runRecordings.stream().filter(runRecording -> "3".equals(runRecording.getFlowStatus()) && runId.equals(runRecording.getRunId())).collect(Collectors.toList()); // List<RunRecording> collect = runRecordings.stream().filter(runRecording -> "3".equals(runRecording.getFlowStatus()) && runId.equals(runRecording.getRunId())).collect(Collectors.toList());
ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(collect), "该实例不是暂停状态！"); // ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(collect), "该实例不是暂停状态！");
StopFlowParam stopFlowParam = new StopFlowParam(); StopFlowParam stopFlowParam = new StopFlowParam();
stopFlowParam.setRunIds(runId); stopFlowParam.setRunIds(runId);
stopFlowParam.setFlowName(flowName); stopFlowParam.setFlowName(flowName);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment