From 5cc64498c08a907616c81e529da2e3a81752cbf4 Mon Sep 17 00:00:00 2001
From: Celes Renata <celes@frameshift.net>
Date: Thu, 16 Apr 2026 09:35:11 +0000
Subject: [PATCH] fix: skip already-propagated docs in aggregation, limit to
 last hour + 10 docs instead of 50

---
 services/aggregation/main.py | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/services/aggregation/main.py b/services/aggregation/main.py
index 8ed520a..f1e564c 100644
--- a/services/aggregation/main.py
+++ b/services/aggregation/main.py
@@ -45,8 +45,14 @@ JOIN documents d ON d.id = di.document_id
 WHERE dir.ticker = $1
   AND di.validation_status = 'valid'
   AND d.status != 'rejected'
+  AND d.created_at >= NOW() - INTERVAL '1 hour'
+  AND NOT EXISTS (
+      SELECT 1 FROM competitive_signal_records csr
+      WHERE csr.source_document_id = di.document_id
+        AND csr.source_ticker = $1
+  )
 ORDER BY d.published_at DESC
-LIMIT 50
+LIMIT 10
 """