diff --git a/application/rebalance_service.py b/application/rebalance_service.py index 2e6aa33..211b6c1 100644 --- a/application/rebalance_service.py +++ b/application/rebalance_service.py @@ -45,7 +45,6 @@ required_semiconductor_rotation_history_lookback, ) from quant_platform_kit.common.strategy_plugins import ( - build_strategy_plugin_notification_lines, build_strategy_plugin_report_payload, load_configured_strategy_plugin_signals, parse_strategy_plugin_mounts, @@ -198,14 +197,9 @@ def attach_strategy_plugin_result( error: str | None, translator: Callable[..., str], ) -> dict[str, Any]: + del translator if signals: result.update(build_strategy_plugin_report_payload(signals)) - notification_lines = build_strategy_plugin_notification_lines( - signals, - translator=translator, - ) - if notification_lines: - result["strategy_plugin_lines"] = notification_lines if error: result["strategy_plugin_error"] = error return result diff --git a/notifications/telegram.py b/notifications/telegram.py index b774b4c..677a0be 100644 --- a/notifications/telegram.py +++ b/notifications/telegram.py @@ -635,7 +635,6 @@ def render_cycle_summary(result: Mapping[str, Any], *, lang: str = "en") -> str: lines.extend(dashboard_lines) lines.extend(_format_timing_lines(execution, translator=translator)) lines.extend(_format_signal_lines(execution, translator=translator)) - lines.extend(str(line).strip() for line in result.get("strategy_plugin_lines") or ()) lines.append(SEPARATOR) lines.extend(target_diff_lines) if submitted: diff --git a/tests/test_rebalance_service.py b/tests/test_rebalance_service.py index 4ff7e3c..9814e4c 100644 --- a/tests/test_rebalance_service.py +++ b/tests/test_rebalance_service.py @@ -278,9 +278,7 @@ def fake_dispatch(signals, **kwargs): assert result["strategy_plugins"][0]["canonical_route"] == "true_crisis" assert result["strategy_plugin_alert_email_sent_count"] == 1 assert result["strategy_plugin_alert_sms_sent_count"] == 1 - assert result["strategy_plugin_lines"] == ( - "🧩 Plugin: Crisis Watch Notice | status: true crisis | notice: defend", - ) + assert "strategy_plugin_lines" not in result assert len(observed_alerts) == 1 assert observed_alerts[0][0][0].canonical_route == "true_crisis" assert "firstrade" in observed_alerts[0][1]["context_label"] @@ -288,7 +286,7 @@ def fake_dispatch(signals, **kwargs): assert observed_alerts[0][1]["state_settings"] is not None assert result["strategy_plugin_alert_email_deliveries"][0]["status"] == "sent" assert result["strategy_plugin_alert_sms_deliveries"][0]["status"] == "sent" - assert "🧩 Plugin: Crisis Watch Notice | status: true crisis | notice: defend" in messages[0] + assert "🧩 Plugin:" not in messages[0] def test_run_strategy_cycle_strategy_plugin_load_error_is_non_blocking(monkeypatch):