Harden plugin notification handling

Author: Pigbibi

notifications/telegram.py

@@ -4,6 +4,13 @@
 
 from notifications.events import NotificationPublisher, RenderedNotification
 
+try:
+    from quant_platform_kit.common.notification_localization import (
+        merge_strategy_plugin_i18n as _merge_strategy_plugin_i18n,
+    )
+except ImportError:  # pragma: no cover - compatibility with older pinned shared wheels
+    _merge_strategy_plugin_i18n = None
+
 
 SIGNAL_ICONS = {
     "hold": "💎",
@@ -131,7 +138,7 @@
         "strategy_plugin_name_macro_risk_governor": "宏观风险控制通知",
         "strategy_plugin_name_market_regime_control": "市场状态控制通知",
         "strategy_plugin_name_panic_reversal_shadow": "恐慌反转观察通知",
-        "strategy_plugin_name_taco_rebound_shadow": "TACO 抄底观察通知",
+        "strategy_plugin_name_taco_rebound_shadow": "TACO 反弹观察通知",
         "strategy_plugin_mode_shadow": "影子观察",
         "strategy_plugin_route_blocked": "已阻断",
         "strategy_plugin_route_crisis": "危机",
@@ -313,6 +320,9 @@
     },
 }
 
+if _merge_strategy_plugin_i18n is not None:
+    I18N = _merge_strategy_plugin_i18n(I18N)
+
 
 def build_translator(lang):
     def translate(key, **kwargs):
@@ -370,7 +380,7 @@ def send_tg_message(message):
             prefixed = with_prefix_fn(message)
             requests_module.post(url, json={"chat_id": chat_id, "text": prefixed}, timeout=10)
         except Exception as exc:
-            print(f"Telegram send failed: {exc}", flush=True)
+            print(f"Telegram send failed: {type(exc).__name__}", flush=True)
 
     return send_tg_message
 

requirements.txt

@@ -1,6 +1,6 @@
 flask
 gunicorn
-quant-platform-kit @ git+https://github.com/QuantStrategyLab/QuantPlatformKit.git@c6e221f71d7be4d8b1c8c94ce05452c3116e0c10
+quant-platform-kit @ git+https://github.com/QuantStrategyLab/QuantPlatformKit.git@d26e8019a0d7d9f1947a0e11bf8829520db60c98
 us-equity-strategies @ git+https://github.com/QuantStrategyLab/UsEquityStrategies.git@2b02dc947d99a593d2bbae4833f0eeeffc2eecd2
 hk-equity-strategies @ git+https://github.com/QuantStrategyLab/HkEquityStrategies.git@5f739744b97d5a9f8981e7ae649c71a0a8ef10fa
 pandas

scripts/cloud_run_runtime_guard.py

@@ -208,7 +208,7 @@ def _send_telegram(message: str) -> bool:
                     print(f"Telegram returned HTTP {response.status}", file=sys.stderr)
         except Exception as exc:  # noqa: BLE001
             ok = False
-            print(f"Telegram send failed: {exc}", file=sys.stderr)
+            print(f"Telegram send failed: {type(exc).__name__}", file=sys.stderr)
     return ok
 
 

scripts/execution_report_heartbeat.py

@@ -653,7 +653,7 @@ def _send_telegram(message: str) -> bool:
                 ok = ok and response.status < 400
         except Exception as exc:  # noqa: BLE001
             ok = False
-            print(f"Telegram send failed: {exc}", file=sys.stderr)
+            print(f"Telegram send failed: {type(exc).__name__}", file=sys.stderr)
     return ok