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