Fixing rules engine (#13)

glerb · Jan 21, 2020 · 50a986b · 50a986b
1 parent 9fcfc42
commit 50a986b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: