feat(telemetry): include total_equity in PerformanceMonitor records (#320)

Pigbibi · claude · cursoragent · web-flow · commit 6131fd776af1 · 2026-07-09T23:57:27.000+08:00
Persist portfolio equity snapshots so QPK ReturnCollector can derive
live daily returns for drift monitoring (task 5).

Co-authored-by: Claude &lt;noreply@anthropic.com&gt;
Co-authored-by: Cursor &lt;cursoragent@cursor.com&gt;
diff --git a/application/rebalance_service.py b/application/rebalance_service.py
@@ -58,6 +58,7 @@ def _record_platform_execution_telemetry(
             "orders_filled": list(summary.get("orders_filled") or ()),
             "orders_skipped": list(summary.get("orders_skipped") or ()),
             "trade_date": summary.get("trade_date") or metadata.get("trade_date"),
+            "total_equity": summary.get("equity") or metadata.get("equity"),
         },
         domain=str(metadata.get("domain") or ""),
     )

Original file line number	Diff line number	Diff line change
`@@ -58,6 +58,7 @@ def _record_platform_execution_telemetry(`
`58`	`58`	`"orders_filled": list(summary.get("orders_filled") or ()),`
`59`	`59`	`"orders_skipped": list(summary.get("orders_skipped") or ()),`
`60`	`60`	`"trade_date": summary.get("trade_date") or metadata.get("trade_date"),`
	`61`	`+ "total_equity": summary.get("equity") or metadata.get("equity"),`
`61`	`62`	`},`
`62`	`63`	`domain=str(metadata.get("domain") or ""),`
`63`	`64`	`)`