From aa3e0784a32b5eb6a2743d0a551645cb862bcc71 Mon Sep 17 00:00:00 2001 From: Pigbibi <20649888+Pigbibi@users.noreply.github.com> Date: Thu, 9 Jul 2026 23:50:01 +0800 Subject: [PATCH] feat(telemetry): include total_equity in PerformanceMonitor records Persist portfolio equity snapshots so QPK ReturnCollector can derive live daily returns for drift monitoring (task 5). Co-Authored-By: Claude Co-authored-by: Cursor --- application/rebalance_service.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/application/rebalance_service.py b/application/rebalance_service.py index 7bc933e..5522333 100644 --- a/application/rebalance_service.py +++ b/application/rebalance_service.py @@ -30,6 +30,7 @@ def _record_platform_execution_telemetry( if not profile: return execution = dict(execution_result.execution or {}) + portfolio = dict(execution_result.portfolio or {}) try_record_platform_execution( profile, { @@ -38,6 +39,7 @@ def _record_platform_execution_telemetry( "effective_date": execution.get("effective_date"), "signal_date": execution.get("signal_date"), "dry_run_only": bool(getattr(config, "dry_run_only", False)), + "total_equity": portfolio.get("total_strategy_equity") or portfolio.get("total_equity"), }, )