Skip to content

Commit ae53cf6

Browse files
authored
[AWSX] fix(logs forwarder): Scrub logs once (#1060)
1 parent 4d4a5f3 commit ae53cf6

1 file changed

Lines changed: 1 addition & 8 deletions

File tree

aws/logs_monitoring/forwarder.py

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -94,16 +94,9 @@ def _forward_logs(self, logs, key=None):
9494
evaluated_log = log
9595
to_forward = None
9696

97-
# apply scrubbing rules to inner log message
9897
if isinstance(log, dict):
9998
if log.get("message"):
100-
try:
101-
log["message"] = scrubber.scrub(log["message"])
102-
evaluated_log = log["message"]
103-
except Exception as e:
104-
logger.error(
105-
f"Exception while scrubbing log message {log['message']}: {e}"
106-
)
99+
evaluated_log = log["message"]
107100
else:
108101
to_forward = dump_event(log)
109102
evaluated_log = to_forward

0 commit comments

Comments
 (0)