diff --git a/src/main/java/ru/nbch/credit_tracker/config/task/ExecutorsConfig.java b/src/main/java/ru/nbch/credit_tracker/config/task/ExecutorsConfig.java
index 645ceaa..1da4685 100644
--- a/src/main/java/ru/nbch/credit_tracker/config/task/ExecutorsConfig.java
+++ b/src/main/java/ru/nbch/credit_tracker/config/task/ExecutorsConfig.java
@@ -41,7 +41,7 @@ public class ExecutorsConfig {
 
     @Bean("lpSaverExecutorService")
     public ExecutorService lpSaverExecutorService(CreditTrackerSettings creditTrackerSettings) {
-        return Executors.newFixedThreadPool(creditTrackerSettings.getNpPipeline().parallelRequests(), r -> {
+        return Executors.newFixedThreadPool(creditTrackerSettings.getLpPipeline().parallelRequests(), r -> {
             Thread t = new Thread(r);
             t.setName("lp-subject-saver-%d".formatted(t.threadId()));
             return t;
diff --git a/src/main/java/ru/nbch/credit_tracker/service/mode/common/StartupRestoreService.java b/src/main/java/ru/nbch/credit_tracker/service/mode/common/StartupRestoreService.java
index 6d2cec7..2cc50d4 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/mode/common/StartupRestoreService.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/mode/common/StartupRestoreService.java
@@ -81,7 +81,7 @@ public class StartupRestoreService {
                 } catch (Exception e) {
                     log.error("Error build default np pipeline for packageId {}: {}", userPackage.getId(), ExceptionUtils.getStackTrace(e));
                 }
-            } else {
+            } else if (userPackage.getSubjectType() == 2) {
                 try {
                     Long count = legalsFidMapMapper.deleteByPackageId(userPackage.getId());
                     log.trace("Deleted {} lp rows", count);
@@ -89,7 +89,7 @@ public class StartupRestoreService {
                     log.debug("Try to read and build lp pipeline for packageId {}; req xml path: {}", userPackage.getId(), xmlReqPath);
                     Pipeline pipeline = lpPipelinePackageManager.build(new SetupParam(userPackage.getId(), 2, PipelineMode.DEFAULT));
                     lpPipelineOrchestrator.startOrDelay(
-                            () -> saver.readAndSaveNpPackage(userPackage.getId(), xmlReqPath),
+                            () -> saver.readAndSaveLpPackage(userPackage.getId(), xmlReqPath),
                             pipeline, userPackage.getId()
                     );
                 } catch (Exception e) {
@@ -111,7 +111,7 @@ public class StartupRestoreService {
                 } catch (Exception e) {
                     log.error("Error build restore np pipeline for packageId {}: {}", userPackage.getId(), ExceptionUtils.getStackTrace(e));
                 }
-            } else {
+            } else if (userPackage.getSubjectType() == 2) {
                 try {
                     log.debug("Build lp pipeline for packageId {}", userPackage.getId());
                     Pipeline pipeline = lpPipelinePackageManager.build(new SetupParam(userPackage.getId(), 2, PipelineMode.DEFAULT));