Merge pull request #10 from de-sh/multiple-log-sources

nikhilsinhaparseable · web-flow · commit 4f7ff4a345c9 · 2025-03-11T13:21:07.000+05:30
test: fix expectation
diff --git a/src/migration/stream_metadata_migration.rs b/src/migration/stream_metadata_migration.rs
@@ -197,7 +197,7 @@ pub fn v5_v6(mut stream_metadata: Value) -> Value {
             log_source_entry = LogSourceEntry::new(log_source, HashSet::new());
         }
     }
-    stream_metadata_map.insert("log_source".to_owned(), json!(log_source_entry));
+    stream_metadata_map.insert("log_source".to_owned(), json!([log_source_entry]));
     stream_metadata
 }
 

Original file line number	Diff line number	Diff line change
`@@ -197,7 +197,7 @@ pub fn v5_v6(mut stream_metadata: Value) -> Value {`
`197`	`197`	`log_source_entry = LogSourceEntry::new(log_source, HashSet::new());`
`198`	`198`	`}`
`199`	`199`	`}`
`200`		`- stream_metadata_map.insert("log_source".to_owned(), json!(log_source_entry));`
	`200`	`+ stream_metadata_map.insert("log_source".to_owned(), json!([log_source_entry]));`
`201`	`201`	`stream_metadata`
`202`	`202`	`}`
`203`	`203`