From 53a2ab77a9d9eea1e51e1d21b14e93752a171b97 Mon Sep 17 00:00:00 2001
From: etreschenkov <ETreschenkov@mfd.ru>
Date: Tue, 11 Nov 2025 14:36:46 +0300
Subject: [PATCH] flag calc

---
 .../credit_tracker/service/task/PipelinePackageManager.java   | 2 +-
 src/main/java/ru/nbch/credit_tracker/service/task/Stage.java  | 4 +++-
 .../credit_tracker/service/task/impl/KickPipeLineImpl.java    | 1 +
 3 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageManager.java b/src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageManager.java
index 0ce6c4e..c3016a7 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageManager.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageManager.java
@@ -110,7 +110,7 @@ public class PipelinePackageManager {
                         }
                         SignalXmlFilePayload res = (SignalXmlFilePayload) v;
                         log.trace("Signal file by path: {} is completed", res.getSignalXmlFilePath());
-                        signalRestService.setupMonitoring(res.getSignalXmlFilePath().toString());
+//                        signalRestService.setupMonitoring(res.getSignalXmlFilePath().toString());
                     } catch (Exception ex) {
                         log.error("pipeline finished with error{}", ExceptionUtils.getStackTrace(ex));
                     } finally {
diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/Stage.java b/src/main/java/ru/nbch/credit_tracker/service/task/Stage.java
index 3f9ae53..478fcaf 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/task/Stage.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/task/Stage.java
@@ -66,7 +66,7 @@ public class Stage<X extends StagePayload, Z extends StagePayload> implements Ru
                 }
                 if (b == null) continue;
                 if (b.isPoison()) {
-                    log.debug("Got poison");
+                    log.info("Got poison");
                     // дождаться всех in-flight задач
                     for (Future<Z> f : inflight) {
                         if (wasInterrupted()) {
@@ -129,6 +129,7 @@ public class Stage<X extends StagePayload, Z extends StagePayload> implements Ru
             }
             q.put(b);
         } catch (InterruptedException e) {
+            log.error("Error: {}", ExceptionUtils.getStackTrace(e));
             Thread.currentThread().interrupt();
         }
     }
@@ -137,6 +138,7 @@ public class Stage<X extends StagePayload, Z extends StagePayload> implements Ru
         try {
             return q.poll(timeout.toMillis(), TimeUnit.MILLISECONDS);
         } catch (InterruptedException e) {
+            log.error("Error: {}", ExceptionUtils.getStackTrace(e));
             Thread.currentThread().interrupt();
             return null;
         }
diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickPipeLineImpl.java b/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickPipeLineImpl.java
index e0d8f2d..150be44 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickPipeLineImpl.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/task/impl/KickPipeLineImpl.java
@@ -62,6 +62,7 @@ public class KickPipeLineImpl implements IPipeLineStarter<SubjectPayload> {
         } catch (IOException e) {
             throw new RuntimeException("Error while parsing monitoring request", e);
         } finally {
+            log.debug("Send poison pill");
             firstQueue.add(new SubjectPayload(true));
         }
     }