diff --git a/src/core/timeline_collect.rs b/src/core/timeline_collect.rs
index 6f45ea6..7db1b66 100644
--- a/src/core/timeline_collect.rs
+++ b/src/core/timeline_collect.rs
@@ -411,6 +411,12 @@ fn collect_discussion_threads(
     // Deduplicate by discussion_id
     let mut seen = HashSet::new();
 
+    let mut stmt = conn.prepare(
+        "SELECT id, author_username, body, created_at FROM notes
+         WHERE discussion_id = ?1 AND is_system = 0
+         ORDER BY created_at ASC",
+    )?;
+
     for disc in matched_discussions {
         if !seen.insert(disc.discussion_id) {
             continue;
@@ -422,12 +428,6 @@ fn collect_discussion_threads(
                 None => continue, // entity not in seed or expanded set
             };
 
-        let mut stmt = conn.prepare(
-            "SELECT id, author_username, body, created_at FROM notes
-             WHERE discussion_id = ?1 AND is_system = 0
-             ORDER BY created_at ASC",
-        )?;
-
         let rows = stmt.query_map(rusqlite::params![disc.discussion_id], |row| {
             Ok((
                 row.get::<_, i64>(0)?,            // id