diff --git a/paperforge/commands/embed.py b/paperforge/commands/embed.py
index e77c46b3..3d4609f1 100644
--- a/paperforge/commands/embed.py
+++ b/paperforge/commands/embed.py
@@ -303,10 +303,10 @@ def run(args: argparse.Namespace) -> int:
                 from paperforge.memory.db import ensure_vec_extension
                 from paperforge.memory.schema import ensure_schema
                 ensure_vec_extension(_conn)
-                ensure_schema(_conn)
                 for _t in ("vec_fulltext", "vec_body", "vec_objects",
                            "vec_fulltext_meta", "vec_body_meta", "vec_objects_meta"):
                     _conn.execute(f'DROP TABLE IF EXISTS "{_t}"')
+                ensure_schema(_conn)
                 _conn.commit()
             except Exception:
                 pass