diff --git a/src/storage/mod.rs b/src/storage/mod.rs
index a17e546..9637028 100644
--- a/src/storage/mod.rs
+++ b/src/storage/mod.rs
@@ -1977,6 +1977,17 @@ fn ensure_todos_schema(conn: &Connection) -> Result<(), StorageError> {
         tracing::info!("Todos table migration complete");
     }
 
+    // Column migration: add created_by_message_id if it doesn't exist
+    let has_column = has_column(&conn, "todos", "created_by_message_id")?;
+    if !has_column {
+        tracing::info!("Adding created_by_message_id column to todos table");
+        conn.execute(
+            "ALTER TABLE todos ADD COLUMN created_by_message_id TEXT",
+            [],
+        )?;
+        tracing::info!("Todos table column migration complete");
+    }
+
     Ok(())
 }