diff --git a/src/bot/bot.py b/src/bot/bot.py
index 28d12e1..9576169 100644
--- a/src/bot/bot.py
+++ b/src/bot/bot.py
@@ -963,10 +963,17 @@ async def cmd_publish(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
             )
             return
 
-        cursor = await db_conn.execute(
-            "SELECT * FROM research_sessions WHERE telegram_chat_id = ? ORDER BY created_at DESC LIMIT 1",
-            (chat_id,)
-        )
+        session_id = _active_sessions.get(chat_id)
+        if session_id:
+            cursor = await db_conn.execute(
+                "SELECT * FROM research_sessions WHERE id = ?",
+                (session_id,)
+            )
+        else:
+            cursor = await db_conn.execute(
+                "SELECT * FROM research_sessions WHERE telegram_chat_id = ? ORDER BY created_at DESC LIMIT 1",
+                (chat_id,)
+            )
         row = await cursor.fetchone()
         if not row:
             await update.message.reply_text("No hay sesiones. Usa /research primero.")