Skip to content

[codex] Harden plugin notification handling #156

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Pigbibi merged 2 commits into from
Jun 16, 2026
Merged

[codex] Harden plugin notification handling #156

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
cd11187
Harden plugin notification handling
Pigbibi Jun 16, 2026
170e854
Update strategy dependency pins
Pigbibi Jun 16, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 12 additions & 2 deletions notifications/telegram.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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": "💎",
Expand Down Expand Up @@ -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": "危机",
Expand Down Expand Up @@ -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):
Expand Down Expand Up @@ -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

Expand Down
6 changes: 3 additions & 3 deletions requirements.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
flask
gunicorn
quant-platform-kit @ git+https://github.com/QuantStrategyLab/QuantPlatformKit.git@c6e221f71d7be4d8b1c8c94ce05452c3116e0c10
us-equity-strategies @ git+https://github.com/QuantStrategyLab/UsEquityStrategies.git@2b02dc947d99a593d2bbae4833f0eeeffc2eecd2
hk-equity-strategies @ git+https://github.com/QuantStrategyLab/HkEquityStrategies.git@5f739744b97d5a9f8981e7ae649c71a0a8ef10fa
quant-platform-kit @ git+https://github.com/QuantStrategyLab/QuantPlatformKit.git@d26e8019a0d7d9f1947a0e11bf8829520db60c98
us-equity-strategies @ git+https://github.com/QuantStrategyLab/UsEquityStrategies.git@ad3b3f72bab07d786f399709b4301ab32a70142b
hk-equity-strategies @ git+https://github.com/QuantStrategyLab/HkEquityStrategies.git@b5988a218008bc945d3904a0fb3a25c95466d741
pandas
requests
pytz
Expand Down
2 changes: 1 addition & 1 deletion scripts/cloud_run_runtime_guard.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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


Expand Down
2 changes: 1 addition & 1 deletion scripts/execution_report_heartbeat.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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


Expand Down