diff --git a/application/src/main/java/dev/jianmu/application/service/ProjectApplication.java b/application/src/main/java/dev/jianmu/application/service/ProjectApplication.java index 34d0221135b0df16cfa76d9551d1b81ef2cf4786..4c338b1eaf1d1f5e120c9bd808788f3e83bb8fde 100644 --- a/application/src/main/java/dev/jianmu/application/service/ProjectApplication.java +++ b/application/src/main/java/dev/jianmu/application/service/ProjectApplication.java @@ -564,6 +564,7 @@ public class ProjectApplication { this.workflowInstanceRepository.findOldDataByRefOffset(project.getWorkflowRef(), this.globalProperties.getGlobal().getRecord().getMax()) .stream() .filter(workflowInstance -> workflowInstance.getStatus() == ProcessStatus.FINISHED || workflowInstance.getStatus() == ProcessStatus.TERMINATED) + .filter(workflowInstance -> this.workflowInstanceRepository.findById(workflowInstance.getId()).isEmpty()) .forEach(workflowInstance -> { this.storageService.deleteWorkflowLog(workflowInstance.getTriggerId()); // 删除触发器事件和web请求