From d9110d03a6abd1f0fc21c2cbd560c4b00b08061c Mon Sep 17 00:00:00 2001
From: Celes Renata <celes@frameshift.net>
Date: Fri, 1 May 2026 04:06:55 +0000
Subject: [PATCH] fix: use di.document_id instead of dir.document_id in
 evidence query

document_impact_records has intelligence_id, not document_id.
The document_id lives on document_intelligence.
---
 services/recommendation/worker.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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'
 """