fix: delete stale trend_evidence before inserting to prevent duplicate accumulation

2026-04-28 19:45:15 +00:00
parent 27b84fcd2e
commit 49bff9de50
1 changed files with 11 additions and 1 deletions
@@ -841,7 +841,11 @@ async def persist_trend_evidence(
    supporting: list[RankedEvidence],
    opposing: list[RankedEvidence],
 ) -> int:
-    """Insert evidence mapping rows for a trend window. Returns count inserted."""
+    """Insert evidence mapping rows for a trend window. Returns count inserted.
+
+    Deletes any existing evidence for this trend window first to prevent
+    duplicate accumulation across aggregation cycles.
+    """
    rows: list[tuple[str, str, str, float, float, float, float, float, float]] = []
    for ev in supporting:
        # Skip non-UUID document IDs (e.g. pattern signal synthetic IDs)
@@ -861,6 +865,12 @@ async def persist_trend_evidence(
            ev.recency_component, ev.confidence_component, ev.sentiment_value,
        ))

+    # Clear stale evidence before inserting fresh rows
+    await pool.execute(
+        "DELETE FROM trend_evidence WHERE trend_window_id = $1",
+        trend_window_id,
+    )
+
    if not rows:
        return 0