Silence IBKR precheck cycle notifications

Author: Pigbibi

application/runtime_composer.py

@@ -11,7 +11,7 @@
 from application.runtime_reporting_adapters import build_runtime_reporting_adapters
 from quant_platform_kit.common.runtime_assembly import build_runtime_assembly
 from quant_platform_kit.common.runtime_target import build_runtime_context_fields
-from quant_platform_kit.common.port_adapters import CallablePortfolioPort
+from quant_platform_kit.common.port_adapters import CallableNotificationPort, CallablePortfolioPort
 from quant_platform_kit.common.runtime_target import RuntimeTarget
 
 
@@ -124,16 +124,21 @@ def build_reporting_adapters(self):
             printer=lambda line: self.printer(line, flush=True),
         )
 
-    def build_rebalance_runtime(self):
+    def build_rebalance_runtime(self, *, silent_cycle_notifications: bool = False):
         notification_adapters = self.build_notification_adapters()
+        notifications = (
+            CallableNotificationPort(lambda _message: None)
+            if silent_cycle_notifications
+            else notification_adapters.notification_port
+        )
         return IBKRRebalanceRuntime(
             connect_ib=self.connect_ib_fn,
             portfolio_port_factory=lambda ib: CallablePortfolioPort(
                 lambda: self.build_portfolio_snapshot_fn(ib)
             ),
             compute_signals=self.compute_signals_fn,
             execute_rebalance=self.execute_rebalance_fn,
-            notifications=notification_adapters.notification_port,
+            notifications=notifications,
         )
 
     def build_rebalance_config(self, *, extra_notification_lines=()):

main.py

@@ -536,7 +536,9 @@ def run_strategy_core(*, strategy_plugin_signals=(), dry_run_only_override: bool
         return run_paper_liquidation_cycle()
     composer = build_composer(dry_run_only_override=dry_run_only_override)
     return run_rebalance_cycle(
-        runtime=composer.build_rebalance_runtime(),
+        runtime=composer.build_rebalance_runtime(
+            silent_cycle_notifications=bool(dry_run_only_override),
+        ),
         config=composer.build_rebalance_config(extra_notification_lines=build_extra_notification_lines(strategy_plugin_signals)),
     )
 

tests/test_runtime_composer.py

@@ -82,6 +82,7 @@ def fake_reporting_builder(**kwargs):
     notification_adapters = composer.build_notification_adapters()
     reporting_adapters = composer.build_reporting_adapters()
     runtime = composer.build_rebalance_runtime()
+    silent_runtime = composer.build_rebalance_runtime(silent_cycle_notifications=True)
     config = composer.build_rebalance_config(extra_notification_lines=("plugin-line",))
 
     assert notification_adapters.notification_port == "notification-port"
@@ -97,6 +98,8 @@ def fake_reporting_builder(**kwargs):
     assert runtime.compute_signals == "compute-signals"
     assert runtime.execute_rebalance == "execute-rebalance"
     assert runtime.notifications == "notification-port"
+    silent_runtime.notifications.send_text("precheck heartbeat")
+    assert "sent_message" not in observed
     assert config.separator == "━━━━━━━━━━━━━━━━━━"
     assert config.strategy_display_name == "全球 ETF 轮动"
     assert config.reconciliation_output_path == "/tmp/reconciliation.json"