diff --git a/services/shared/metadata.py b/services/shared/metadata.py
index ac15db3..46c3c01 100644
--- a/services/shared/metadata.py
+++ b/services/shared/metadata.py
@@ -209,12 +209,17 @@ async def persist_broker_event(
 
 
 def _resolve_document_type(source_type: str) -> str:
-    """Map source_type to a document_type value."""
+    """Map source_type to a document_type value.
+
+    Note: macro_news articles default to 'article' — the extractor
+    reclassifies them as 'macro_event' only if the content is truly
+    about macro/global events (not company-specific news).
+    """
     mapping = {
         "news_api": "article",
         "filings_api": "filing",
         "web_scrape": "press_release",
-        "macro_news": "macro_event",
+        "macro_news": "article",
     }
     return mapping.get(source_type, "article")