diff --git a/internal/log_analysis/rules_engine/src/main.py b/internal/log_analysis/rules_engine/src/main.py
index 8cc607a340..af6211bc1f 100644
--- a/internal/log_analysis/rules_engine/src/main.py
+++ b/internal/log_analysis/rules_engine/src/main.py
@@ -48,7 +48,7 @@ def lambda_handler(event: Dict[str, Any], unused_context) -> None:
     for log_type, data_streams in log_type_to_data.items():
         for data_stream in data_streams:
             for data in data_stream:
-                for matched_rule in rules_engine.analyze(log_type, data):
+                for matched_rule in rules_engine.analyze(log_type, json.loads(data)):
                     matched.append((matched_rule, data))
 
     if len(matched) > 0: