Show strategy plugin load errors in notifications

Author: Pigbibi

src/quant_platform_kit/common/__init__.py

@@ -70,6 +70,7 @@
     build_strategy_plugin_alert_key,
     build_strategy_plugin_alert_messages,
     build_strategy_plugin_alert_scope_note,
+    build_strategy_plugin_error_notification_lines,
     build_strategy_plugin_notification_lines,
     build_strategy_plugin_report_payload,
     extract_strategy_plugin_localized_message,
@@ -148,6 +149,7 @@
     "build_strategy_plugin_alert_key",
     "build_strategy_plugin_alert_messages",
     "build_strategy_plugin_alert_scope_note",
+    "build_strategy_plugin_error_notification_lines",
     "build_strategy_plugin_notification_lines",
     "build_strategy_plugin_report_payload",
     "extract_strategy_plugin_localized_message",

src/quant_platform_kit/common/notification_localization.py

@@ -30,6 +30,13 @@
         "strategy_plugin_alert_reason_joiner": "、",
         "strategy_plugin_alert_reason_none": "未提供明确原因",
         "strategy_plugin_line": "🧩 插件：{plugin} | 状态：{route} | 提醒：{action}",
+        "strategy_plugin_error_line": "⚠️ 插件信号未加载：{reason}；本轮使用策略内置规则",
+        "strategy_plugin_error_reason_JSONDecodeError": "插件配置 JSON 格式错误",
+        "strategy_plugin_error_reason_FileNotFoundError": "插件信号文件不存在",
+        "strategy_plugin_error_reason_PermissionError": "插件信号文件权限不足",
+        "strategy_plugin_error_reason_ValueError": "插件配置校验失败",
+        "strategy_plugin_error_reason_OSError": "插件信号文件读取失败",
+        "strategy_plugin_error_reason_default": "插件加载异常（技术详情见执行报告）",
         "strategy_plugin_alert_subject": "策略插件提醒：{plugin} | {route}",
         "strategy_plugin_alert_title": "【策略插件提醒】",
         "strategy_plugin_alert_context": "发布来源：{context}",
@@ -113,6 +120,13 @@
         "strategy_plugin_alert_reason_joiner": ", ",
         "strategy_plugin_alert_reason_none": "no explicit reason provided",
         "strategy_plugin_line": "🧩 Plugin: {plugin} | status: {route} | notice: {action}",
+        "strategy_plugin_error_line": "⚠️ Plugin signal failed to load: {reason}; this run falls back to built-in strategy rules",
+        "strategy_plugin_error_reason_JSONDecodeError": "invalid plugin mount JSON",
+        "strategy_plugin_error_reason_FileNotFoundError": "plugin signal file not found",
+        "strategy_plugin_error_reason_PermissionError": "plugin signal file permission denied",
+        "strategy_plugin_error_reason_ValueError": "plugin configuration validation failed",
+        "strategy_plugin_error_reason_OSError": "plugin signal file read failed",
+        "strategy_plugin_error_reason_default": "plugin load failed; see execution report diagnostics",
         "strategy_plugin_alert_subject": "Strategy plugin notice: {plugin} | {route}",
         "strategy_plugin_alert_title": "【Strategy Plugin Notice】",
         "strategy_plugin_alert_context": "Source: {context}",

src/quant_platform_kit/common/strategy_plugins.py

@@ -928,6 +928,65 @@ def build_strategy_plugin_notification_lines(
     return tuple(lines)
 
 
+def _compact_strategy_plugin_error(error: object, *, max_chars: int = 240) -> str:
+    text = " ".join(str(error or "").split())
+    if not text:
+        return ""
+    if len(text) <= max_chars:
+        return text
+    return text[: max_chars - 1].rstrip() + "…"
+
+
+def _translator_uses_zh(translator: Callable[..., str] | None) -> bool:
+    if translator is None:
+        return False
+    for key in ("strategy_plugin_alert_locale", "no_trades"):
+        try:
+            sample = str(translator(key))
+        except Exception:
+            continue
+        if sample.strip().lower().startswith("zh"):
+            return True
+        if any("\u4e00" <= char <= "\u9fff" for char in sample):
+            return True
+    return False
+
+
+def _strategy_plugin_error_reason(error: object, *, translator: Callable[..., str] | None = None) -> str:
+    detail = _compact_strategy_plugin_error(error)
+    if not detail:
+        return ""
+    error_type = detail.split(":", 1)[0].rsplit(".", 1)[-1].strip()
+    reason_key = f"strategy_plugin_error_reason_{error_type}" if error_type else ""
+    if translator is not None and reason_key:
+        translated = translator(reason_key)
+        if translated != reason_key:
+            return translated
+    if _translator_uses_zh(translator):
+        translated = translator("strategy_plugin_error_reason_default") if translator is not None else ""
+        if translated and translated != "strategy_plugin_error_reason_default":
+            return translated
+    return detail
+
+
+def build_strategy_plugin_error_notification_lines(
+    error: object,
+    *,
+    translator: Callable[..., str] | None = None,
+) -> tuple[str, ...]:
+    reason = _strategy_plugin_error_reason(error, translator=translator)
+    if not reason:
+        return ()
+    return (
+        _translate(
+            translator,
+            "strategy_plugin_error_line",
+            fallback="Plugin signal failed to load: {reason}; this run falls back to built-in strategy rules",
+            reason=reason,
+        ),
+    )
+
+
 def should_alert_strategy_plugin_signal(signal: StrategyPluginSignal) -> bool:
     route = _normalize_strategy_plugin_field(getattr(signal, "canonical_route", None))
     action = _normalize_strategy_plugin_field(getattr(signal, "suggested_action", None))

tests/test_strategy_plugins.py

@@ -27,6 +27,7 @@
     StrategyPluginDefinition,
     attach_strategy_plugin_metadata,
     build_strategy_plugin_alert_messages,
+    build_strategy_plugin_error_notification_lines,
     build_strategy_plugin_notification_lines,
     build_strategy_plugin_report_payload,
     extract_strategy_plugin_localized_message,
@@ -573,6 +574,8 @@ def test_strategy_plugin_notification_lines_use_translator_when_available(self):
         signal = validate_strategy_plugin_signal_payload(_signal_payload())
         translations = {
             "strategy_plugin_line": "plugin={plugin}|mode={mode}|route={route}|action={action}",
+            "strategy_plugin_error_line": "plugin-error={reason}|fallback=built-in",
+            "strategy_plugin_error_reason_ValueError": "config validation failed",
             "strategy_plugin_name_crisis_response_shadow": "Crisis",
             "strategy_plugin_mode_shadow": "shadow",
             "strategy_plugin_route_no_action": "no action",
@@ -587,6 +590,15 @@ def test_strategy_plugin_notification_lines_use_translator_when_available(self):
         )
 
         self.assertEqual(lines, ("plugin=Crisis|mode=shadow|route=no action|action=watch only",))
+        self.assertEqual(
+            build_strategy_plugin_error_notification_lines(
+                "ValueError: bad config\ntrace line",
+                translator=lambda key, **kwargs: translations.get(key, key).format(**kwargs)
+                if kwargs
+                else translations.get(key, key),
+            ),
+            ("plugin-error=config validation failed|fallback=built-in",),
+        )
 
     def test_strategy_plugin_notification_lines_can_use_artifact_localized_message(self):
         signal = validate_strategy_plugin_signal_payload(