diff --git a/services/recommendation/worker.py b/services/recommendation/worker.py
index b55d90f..1d1aeba 100644
--- a/services/recommendation/worker.py
+++ b/services/recommendation/worker.py
@@ -748,7 +748,7 @@ def _map_time_horizon_prefix(window: str) -> str:
 
 _EVIDENCE_SIGNALS_QUERY = """
 SELECT
-    dir.document_id::text AS document_id,
+    di.document_id::text AS document_id,
     di.id::text AS signal_id,
     dir.ticker,
     d.source_type AS source,
@@ -761,7 +761,7 @@ SELECT
 FROM document_impact_records dir
 JOIN document_intelligence di ON di.id = dir.intelligence_id
 JOIN documents d ON d.id = di.document_id
-WHERE dir.document_id = ANY($1::uuid[])
+WHERE di.document_id = ANY($1::uuid[])
   AND di.validation_status = 'valid'
 """