From 50564d090b080de94634ec95b95e4c2df95b3297 Mon Sep 17 00:00:00 2001
From: Georgi <georgi.ajaeiya@datadoghq.com>
Date: Tue, 3 Feb 2026 17:05:06 +0100
Subject: [PATCH] [AWSX] fix(logs forwarder): Scrub logs once

---
 aws/logs_monitoring/forwarder.py | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

diff --git a/aws/logs_monitoring/forwarder.py b/aws/logs_monitoring/forwarder.py
index d50677216..be18b9d65 100644
--- a/aws/logs_monitoring/forwarder.py
+++ b/aws/logs_monitoring/forwarder.py
@@ -94,16 +94,9 @@ def _forward_logs(self, logs, key=None):
             evaluated_log = log
             to_forward = None
 
-            # apply scrubbing rules to inner log message
             if isinstance(log, dict):
                 if log.get("message"):
-                    try:
-                        log["message"] = scrubber.scrub(log["message"])
-                        evaluated_log = log["message"]
-                    except Exception as e:
-                        logger.error(
-                            f"Exception while scrubbing log message {log['message']}: {e}"
-                        )
+                    evaluated_log = log["message"]
                 else:
                     to_forward = dump_event(log)
                     evaluated_log = to_forward