From bcf721448d88f0c9629e12da671a4bf1bc696df2 Mon Sep 17 00:00:00 2001
From: xiaowu <xiaowu@shellway.wang>
Date: Sat, 15 Aug 2026 10:33:08 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=A2=9E=E9=87=8F=E8=84=9A=E6=9C=AC?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97=E5=8E=BB=E9=87=8D=20+=20index=5Fdaily=20?=
 =?UTF-8?q?=E7=A9=BA=E8=A1=A8=E8=87=AA=E5=8A=A8=E5=88=9D=E5=A7=8B=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 quantitative_data/incremental_import.py | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/quantitative_data/incremental_import.py b/quantitative_data/incremental_import.py
index fa5f5f3..49a5e87 100644
--- a/quantitative_data/incremental_import.py
+++ b/quantitative_data/incremental_import.py
@@ -38,6 +38,7 @@ from importer import (
 )
 
 logger = logging.getLogger("incremental")
+logger.propagate = False
 if not logger.handlers:
     h = logging.StreamHandler()
     h.setFormatter(logging.Formatter("%(asctime)s [%(levelname)s] %(message)s"))
@@ -109,7 +110,12 @@ def run_daily(end_date, dry_run, limit):
     ]:
         max_d = get_max_date(conn, table, date_col)
         if max_d is None:
-            logger.warning(f"  {table}: 表为空，请先执行全量导入 (full_import)")
+            if table == "index_daily":
+                logger.warning("  index_daily: 表为空，自动全量初始化（6个指数，很快）")
+                if not dry_run:
+                    import_index_daily(start_date=None, end_date=end_date)
+            else:
+                logger.warning(f"  {table}: 表为空，请先执行全量导入 (full_import)")
             continue
         start = (max_d + timedelta(days=1)).strftime("%Y-%m-%d")
         if start > end_date: