From bb7606125a09f388cbf9ae6d5af412dcb69cbab7 Mon Sep 17 00:00:00 2001
From: etreschenkov <ETreschenkov@mfd.ru>
Date: Tue, 14 Oct 2025 15:21:40 +0300
Subject: [PATCH] ./

---
 .../ru/nbch/credit_tracker/facade/SignalFacadeV2.java    | 1 +
 .../nbch/credit_tracker/service/task/TaskConsumerV2.java | 9 ++++++++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/main/java/ru/nbch/credit_tracker/facade/SignalFacadeV2.java b/src/main/java/ru/nbch/credit_tracker/facade/SignalFacadeV2.java
index 588123b..c020242 100644
--- a/src/main/java/ru/nbch/credit_tracker/facade/SignalFacadeV2.java
+++ b/src/main/java/ru/nbch/credit_tracker/facade/SignalFacadeV2.java
@@ -98,6 +98,7 @@ public class SignalFacadeV2 {
 
             Long packageId = signalService.registerPackage(userId, packageName);
             log.info("Package registered. PackageId {}. Status: {}", packageId, Status.PROCESSING.name());
+            //create and start pipilene
             savingRequest.add(new PackageToSavePayload(packageId, filePath));
         } catch (Exception e) {
             CTUtil.removeFile(filePath);
diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/TaskConsumerV2.java b/src/main/java/ru/nbch/credit_tracker/service/task/TaskConsumerV2.java
index 6ca9505..6985043 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/task/TaskConsumerV2.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/task/TaskConsumerV2.java
@@ -51,7 +51,14 @@ public class TaskConsumerV2<X extends TaskPayloadV2, Z extends TaskPayloadV2>
                     putQuiet(out, POISON);
                     return;
                 }
-                Future<Z> f = ioPool.submit(() -> dispatcher.handle(b));
+
+                Future<Z> f = ioPool.submit(() -> {
+                        Z p = dispatcher.handle(b);
+                        //
+                        putQuiet(out, p);
+                        return p;
+                    }
+                );
                 inflight.add(f);
 
                 // чтобы не накапливать слишком много future в памяти, периодически сливаем