From ebc26c05af0098faa206b2b048e05156d0008fec Mon Sep 17 00:00:00 2001
From: MatiasVillanueva97 <mavillanueva@frba.utn.edu.ar>
Date: Thu, 19 Feb 2026 18:12:33 -0300
Subject: [PATCH 1/2] fix: get message from Message object

---
 src/sources/aws.sqs.source.coffee | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/sources/aws.sqs.source.coffee b/src/sources/aws.sqs.source.coffee
index b9c4f5d..ec7da6c 100644
--- a/src/sources/aws.sqs.source.coffee
+++ b/src/sources/aws.sqs.source.coffee
@@ -2,7 +2,7 @@ _ = require "lodash"
 
 module.exports =
   newNotification: ({ context, message }) ->
-    message: message
+    message: if(!_.isObject(message.Message)) then JSON.parse(message.Message) else message.Message
     meta: {
       insertionTime:  _.get(context, "bindingData.sentTimestamp"),
       dequeueCount: _.get(context, "bindingData.approximateReceiveCount"),

From 07bab16acd79f3fceb24a61139b51795537e2cc7 Mon Sep 17 00:00:00 2001
From: MatiasVillanueva97 <mavillanueva@frba.utn.edu.ar>
Date: Thu, 19 Feb 2026 19:40:33 -0300
Subject: [PATCH 2/2] fix: add logs

---
 src/processors/job/job.processor.coffee    | 5 +++++
 src/processors/job/notification.api.coffee | 3 +++
 src/processors/maxRetries.processor.coffee | 1 +
 3 files changed, 9 insertions(+)

diff --git a/src/processors/job/job.processor.coffee b/src/processors/job/job.processor.coffee
index fdab563..964ea45 100644
--- a/src/processors/job/job.processor.coffee
+++ b/src/processors/job/job.processor.coffee
@@ -32,7 +32,12 @@ module.exports =
         request: _.omit error.detail.request, ["resolveWithFullResponse"]
       }
       @_ifJobIsNotStopped message, () => 
+        console.log("Max retry exceeded for job #{message.JobId} with error #{errorMessage.error}")
+        console.log("Sending NotificationsApi fail")
         @_notificationsApi(message).fail errorMessage
+          .then (response) =>
+            console.log("NotificationsApi fail response: #{response}")
+            response
           .throw new NonRetryable "Max retry exceeded", error
 
     _notificationsApi: ({ HeadersForRequest, JobId }) =>
diff --git a/src/processors/job/notification.api.coffee b/src/processors/job/notification.api.coffee
index 5dd8c7a..ec069be 100644
--- a/src/processors/job/notification.api.coffee
+++ b/src/processors/job/notification.api.coffee
@@ -75,6 +75,9 @@ class NotificationsApi
       throw e if options.useAsyncApi
       console.log("Error sending status to notifications-api. Retrying via notifications-api-async")
       retryRequest()
+    .tapCatch (e) =>
+      console.log("Error sending status to notifications-api-async. Ignoring error.")
+      console.log(e)
     .catchReturn()
 
   _makeRequest: (body, { useAsyncApi } = {}) =>
diff --git a/src/processors/maxRetries.processor.coffee b/src/processors/maxRetries.processor.coffee
index b5dc9b6..89934da 100644
--- a/src/processors/maxRetries.processor.coffee
+++ b/src/processors/maxRetries.processor.coffee
@@ -15,6 +15,7 @@ module.exports =
         @_onMaxRetryExceeded_ notification, err
 
     _shouldRetry_: ({ meta: { dequeueCount = 0 } }, err) ->
+      console.log("dequeue count is #{dequeueCount} and max retries is #{@maxRetries}")
       dequeueCount < @maxRetries
 
     _onSuccess_: (notification, result) -> throw new Error "subclass responsability"