feat(telemetry): persist total_equity for live return series (#214)

Pigbibi · claude · cursoragent · web-flow · commit 86cfbcae46c2 · 2026-07-10T00:00:57.000+08:00
* 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 &lt;noreply@anthropic.com&gt;
Co-authored-by: Cursor &lt;cursoragent@cursor.com&gt;

* chore(ci): retrigger gate after cancelled run

Co-authored-by: Cursor &lt;cursoragent@cursor.com&gt;

---------

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
@@ -741,6 +741,8 @@ def log_message(message: str) -> None:
             "submitted_orders": result.get("submitted_orders"),
             "skipped_orders": result.get("skipped_orders"),
             "error": result.get("error"),
+            "total_equity": (result.get("portfolio") or {}).get("total_equity")
+            or (result.get("portfolio") or {}).get("equity"),
         },
     )
     return result

Original file line number	Diff line number	Diff line change
`@@ -741,6 +741,8 @@ def log_message(message: str) -> None:`
`741`	`741`	`"submitted_orders": result.get("submitted_orders"),`
`742`	`742`	`"skipped_orders": result.get("skipped_orders"),`
`743`	`743`	`"error": result.get("error"),`
	`744`	`+ "total_equity": (result.get("portfolio") or {}).get("total_equity")`
	`745`	`+ or (result.get("portfolio") or {}).get("equity"),`
`744`	`746`	`},`
`745`	`747`	`)`
`746`	`748`	`return result`