Skip to content

Commit 6dddca0

Browse files
Pigbibiclaudecursoragent
authored
feat(telemetry): record platform executions in PerformanceMonitor (#213)
Wire try_record_platform_execution on rebalance cycle completion so live runs feed QPK drift/performance pipelines (roadmap task 5). Co-authored-by: Claude <noreply@anthropic.com> Co-authored-by: Cursor <cursoragent@cursor.com>
1 parent 2feffaf commit 6dddca0

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

application/rebalance_service.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@
6060
publish_strategy_plugin_alerts as dispatch_strategy_plugin_alerts,
6161
)
6262
from quant_platform_kit.strategy_contracts import build_strategy_evaluation_inputs
63+
from quant_platform_kit.strategy_lifecycle.performance_monitor import try_record_platform_execution
6364
from runtime_config_support import IBIT_SMART_DCA_PROFILE, PlatformRuntimeSettings, load_platform_runtime_settings
6465
from runtime_execution_policy import dca_execution_unsupported_reason, notional_buy_execution_enabled
6566
from us_equity_strategies.signals import resolve_external_market_signal_inputs
@@ -730,4 +731,16 @@ def log_message(message: str) -> None:
730731
else:
731732
result["notification_sent"] = False
732733
result["notification_suppressed"] = True
734+
try_record_platform_execution(
735+
strategy_runtime.profile,
736+
{
737+
"platform": "firstrade",
738+
"action_done": result.get("action_done"),
739+
"strategy_run_stage": result.get("strategy_run_stage"),
740+
"dry_run_only": settings.dry_run_only,
741+
"submitted_orders": result.get("submitted_orders"),
742+
"skipped_orders": result.get("skipped_orders"),
743+
"error": result.get("error"),
744+
},
745+
)
733746
return result

0 commit comments

Comments
 (0)