diff --git a/src/main/java/ru/nbch/credit_tracker/service/StartupRestoreService.java b/src/main/java/ru/nbch/credit_tracker/service/StartupRestoreService.java index 1fab93f..4de6e2f 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/StartupRestoreService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/StartupRestoreService.java @@ -87,10 +87,10 @@ public class StartupRestoreService { private void processingRestore() { List packages = userPackageMapper.findAllPackagesByStatus(Status.PROCESSING.name(), Status.PROCESSING_REPEATED.name()); - packages = packages.stream().filter(userPackage -> userPackage.getRejectStatus() == null).toList(); - log.debug("Found {} packages in status PROCESSING and rejected_status = null", packages.size()); + log.debug("Found {} packages in status PROCESSING", packages.size()); for (UserPackage userPackage : packages) { try { + log.debug("Build pipeline for packageId {}", userPackage.getId()); Pipeline pipeline = pipelinePackageManager.build(new SetupParam(userPackage.getId(), null, PipelineMode.DEFAULT)); pipelineOrchestrator.startOrDelay(pipeline, userPackage.getId()); } catch (Exception e) {