update

app/ingest/tushare.py

@@ -1536,25 +1536,7 @@ def ensure_data_coverage(
                 LOGGER.exception("外汇行情拉取失败：%s", code)
                 raise
 
-        advance("拉取港/美股行情数据")
+        advance("拉取港/美股行情数据（已暂时关闭）")
-        for code in HK_CODES:
-            try:
-                if not force and _should_skip_range("hk_daily", "trade_date", start, end, code):
-                    LOGGER.info("港股 %s 已覆盖 %s-%s，跳过", code, start_str, end_str)
-                    continue
-                save_records("hk_daily", fetch_hk_daily(start, end, code))
-            except Exception:
-                LOGGER.exception("港股行情拉取失败：%s", code)
-                raise
-        for code in US_CODES:
-            try:
-                if not force and _should_skip_range("us_daily", "trade_date", start, end, code):
-                    LOGGER.info("美股 %s 已覆盖 %s-%s，跳过", code, start_str, end_str)
-                    continue
-                save_records("us_daily", fetch_us_daily(start, end, code))
-            except Exception:
-                LOGGER.exception("美股行情拉取失败：%s", code)
-                raise
 
     if progress_hook:
         progress_hook("数据覆盖检查完成", 1.0)

app/utils/config.py

@@ -55,7 +55,6 @@ class AppConfig:
     data_paths: DataPaths = field(default_factory=DataPaths)
     agent_weights: AgentWeights = field(default_factory=AgentWeights)
     force_refresh: bool = False
-    max_calls_per_minute: int = 180
 
 
 CONFIG = AppConfig()

app/utils/logging.py

@@ -110,7 +110,6 @@ def setup_logging(
                 "force_refresh": cfg.force_refresh,
                 "data_root": str(cfg.data_paths.root),
                 "logfile": str(logfile),
-                "max_calls_per_minute": cfg.max_calls_per_minute,
             },
         },
     )