From aa84ce1fa94d5ee52b71e7f4ae21c86e55624f61 Mon Sep 17 00:00:00 2001
From: Manikandan-tm <manikandan.tm@zucisystems.com>
Date: Thu, 1 Jun 2023 20:41:05 +0530
Subject: [PATCH] paper itemiser indexing issue

---
 src/main/java/in/handyman/raven/lib/CoproProcessor.java   | 2 +-
 src/main/java/in/handyman/raven/lib/FileMergerAction.java | 7 +++++--
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/java/in/handyman/raven/lib/CoproProcessor.java b/src/main/java/in/handyman/raven/lib/CoproProcessor.java
index 6ab9fb30a..538ab43f5 100644
--- a/src/main/java/in/handyman/raven/lib/CoproProcessor.java
+++ b/src/main/java/in/handyman/raven/lib/CoproProcessor.java
@@ -58,7 +58,7 @@ public CoproProcessor(final BlockingQueue<I> queue, final Class<O> outputTargetC
         this.executorService = Executors.newWorkStealingPool();
         this.outputTargetClass = outputTargetClass;
         this.jdbi = jdbi;
-        this.logger = log;
+        this.logger = logger;
         this.actionExecutionAudit = actionExecutionAudit;
         this.nodeSize = coproNodes.size();
         final LocalDateTime startTime = LocalDateTime.now();
diff --git a/src/main/java/in/handyman/raven/lib/FileMergerAction.java b/src/main/java/in/handyman/raven/lib/FileMergerAction.java
index 6a883a331..b96944073 100644
--- a/src/main/java/in/handyman/raven/lib/FileMergerAction.java
+++ b/src/main/java/in/handyman/raven/lib/FileMergerAction.java
@@ -58,17 +58,20 @@ public void execute() throws Exception {
         if(log.isInfoEnabled()){
             log.info(aMarker, "The request got it successfully the copro url {} ,request body {} and output directory  {}", URI,requestBody,outputDir);
         }
+        String name = "file-merger-response";
         try (Response response = httpclient.newCall(request).execute()) {
             String responseBody = Objects.requireNonNull(response.body()).string();
-            String name = "file-merger-response";
             if (response.isSuccessful()) {
                 action.getContext().put(name, mapper.readTree(responseBody).toString());
+                action.getContext().put(name.concat(".success"), "true");
                 log.info(aMarker, "The Successful Response  {} {}", name, responseBody);
             } else {
+                action.getContext().put(name.concat(".error"), "true");
                 log.error(aMarker, "The Failure Response  {} {}", name, responseBody);
             }
         } catch (Exception e) {
-            log.info(aMarker, "The Exception occurred ", e);
+            action.getContext().put(name.concat(".error"), "true");
+            log.error(aMarker, "The Exception occurred ", e);
             throw new HandymanException("Failed to execute", e, action);
         }
     }