diff --git a/backend/services/database.py b/backend/services/database.py
index 81cb8b4..9f30a7b 100644
--- a/backend/services/database.py
+++ b/backend/services/database.py
@@ -4595,13 +4595,14 @@ def update_market_event(event_id: int, ev: Dict[str, Any]) -> bool:
         if isinstance(src_refs, list):
             src_refs = json.dumps(src_refs)
         conn.execute("""UPDATE market_events SET
-            name=?, start_date=?, end_date=?, level=?, category=?, description=?,
-            market_impact=?, affected_assets=?, impact_score=?,
+            name=?, start_date=?, end_date=?, level=?, category=?, sub_type=?,
+            description=?, market_impact=?, affected_assets=?, impact_score=?,
             absorption_pct=?, relevant_indicators=?, source_refs=?, origin=?
             WHERE id=?""",
             (ev["name"], ev["start_date"], ev.get("end_date"),
-             ev["level"], ev.get("category", "macro"), ev.get("description", ""),
-             ev.get("market_impact", ""), json.dumps(ev.get("affected_assets", [])),
+             ev["level"], ev.get("category", "macro"), ev.get("sub_type", ""),
+             ev.get("description", ""), ev.get("market_impact", ""),
+             json.dumps(ev.get("affected_assets", [])),
              ev.get("impact_score", 0.5),
              ev.get("absorption_pct"), json.dumps(ev.get("relevant_indicators", [])),
              src_refs, ev.get("origin", "unknown"), event_id))