From 79593a8fd3706fcfcc71494161dbc4ec70d4ce98 Mon Sep 17 00:00:00 2001 From: OpenSquared Date: Mon, 29 Jun 2026 12:38:28 +0200 Subject: [PATCH] feat: instrument analysis --- backend/routers/causal_lab.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/backend/routers/causal_lab.py b/backend/routers/causal_lab.py index d5a40bd..d956407 100644 --- a/backend/routers/causal_lab.py +++ b/backend/routers/causal_lab.py @@ -984,6 +984,9 @@ def analyze_event(body: AnalyzeRequest): "SELECT id FROM causal_event_analyses WHERE market_event_id=? AND template_id=?", (body.market_event_id, body.template_id), ).fetchone() + # Stocker tous les instruments analysés pour que la frise Instrument Analysis les retrouve + all_instruments_csv = ",".join(sorted(drift_by_inst.keys())) or primary_inst + if existing: conn.execute(""" UPDATE causal_event_analyses @@ -991,7 +994,7 @@ def analyze_event(body: AnalyzeRequest): actual_json=?, activation_score=?, drift_json=?, analyzed_at=? WHERE market_event_id=? AND template_id=? """, ( - primary_inst, json.dumps(inputs), json.dumps(body.coef_overrides), + all_instruments_csv, json.dumps(inputs), json.dumps(body.coef_overrides), json.dumps(node_values), json.dumps(actual_moves), activation.get("score"), json.dumps(drift_by_inst), analyzed_at, body.market_event_id, body.template_id, @@ -1004,7 +1007,7 @@ def analyze_event(body: AnalyzeRequest): activation_score, drift_json, analyzed_at) VALUES (?,?,?,?,?,?,?,?,?,?) """, ( - body.market_event_id, body.template_id, primary_inst, + body.market_event_id, body.template_id, all_instruments_csv, json.dumps(inputs), json.dumps(body.coef_overrides), json.dumps(node_values), json.dumps(actual_moves), activation.get("score"),