fix: generic flattening only for non otel sources

nikhilsinhaparseable · Jan 5, 2025 · cca61b7 · cca61b7
1 parent a32e4b3
commit cca61b7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/utils/json/mod.rs b/src/utils/json/mod.rs
@@ -38,7 +38,7 @@ pub fn flatten_json_body(
     let mut nested_value = if schema_version == SchemaVersion::V1
         && matches!(
             log_source,
-            LogSource::OtelLogs | LogSource::OtelMetrics | LogSource::OtelTraces
+            LogSource::Json | LogSource::Custom(_) | LogSource::Kinesis
         ) {
         flatten::generic_flattening(body)?
     } else {