diff --git a/src/blackboard/db.py b/src/blackboard/db.py
index 774c5d5..73d58cb 100644
--- a/src/blackboard/db.py
+++ b/src/blackboard/db.py
@@ -60,6 +60,8 @@ def _migrate_v28(conn: sqlite3.Connection) -> None:
     ).fetchone()
     if row and "paused" not in row["sql"]:
         # 重建 tasks 表以更新 CHECK 约束
+        # 幂等检查：如果 tasks_v28 已存在（上次中断），先清理
+        conn.execute("DROP TABLE IF EXISTS tasks_v28")
         conn.executescript("""
             CREATE TABLE tasks_v28 (
                 id TEXT PRIMARY KEY,