From c188677330e65956476044d5baf8546efb75aca3 Mon Sep 17 00:00:00 2001 From: Celes Renata Date: Tue, 28 Apr 2026 16:18:02 +0000 Subject: [PATCH] fix: route macro_news documents as macro_event so global event classification runs --- services/shared/metadata.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/services/shared/metadata.py b/services/shared/metadata.py index 46c3c01..db65d78 100644 --- a/services/shared/metadata.py +++ b/services/shared/metadata.py @@ -211,15 +211,15 @@ async def persist_broker_event( def _resolve_document_type(source_type: str) -> str: """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). + Note: macro_news articles are typed as 'macro_event' so the parser + routes them to the macro classification queue for global event + extraction rather than standard company-level extraction. """ mapping = { "news_api": "article", "filings_api": "filing", "web_scrape": "press_release", - "macro_news": "article", + "macro_news": "macro_event", } return mapping.get(source_type, "article")