diff --git a/app/database.py b/app/database.py
index 8f7a56b..35fccfc 100644
--- a/app/database.py
+++ b/app/database.py
@@ -64,7 +64,8 @@ async def init_db():
         """)
 
         # Migration: drucksache-Spalte zu jobs (für Queue-Resume nach Restart)
-        cols = {r[1] for r in await db.execute("PRAGMA table_info(jobs)")}
+        cursor = await db.execute("PRAGMA table_info(jobs)")
+        cols = {r[1] for r in await cursor.fetchall()}
         if "drucksache" not in cols:
             await db.execute("ALTER TABLE jobs ADD COLUMN drucksache TEXT")