From abfb805e4fb453e04efe16b527f937cd2e48fd69 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Thu, 22 Jan 2026 12:15:58 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/BKI-3241 --- .../ru/nbch/credit_tracker/service/StartupRestoreService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) {