diff --git a/services/aggregation/worker.py b/services/aggregation/worker.py index a3ca6d0..2f9ce1d 100644 --- a/services/aggregation/worker.py +++ b/services/aggregation/worker.py @@ -460,7 +460,7 @@ def assemble_trend_with_evidence( _UPSERT_TREND = """ INSERT INTO trend_windows ( - entity_type, entity_id, window, trend_direction, trend_strength, + entity_type, entity_id, "window", trend_direction, trend_strength, confidence, top_supporting_evidence, top_opposing_evidence, dominant_catalysts, material_risks, contradiction_score, disagreement_details, market_context, generated_at