diff --git a/scripts/data_platform/migrate_constituent.py b/scripts/data_platform/migrate_constituent.py
index 821c3dd..2ce65dc 100644
--- a/scripts/data_platform/migrate_constituent.py
+++ b/scripts/data_platform/migrate_constituent.py
@@ -158,9 +158,11 @@ def migrate(db_path: str) -> None:
         pool["source"] = "baostock"
         print(f"[baostock] pool rows={len(pool)} (300/500/50 全集)")
 
-        # 2. 深证 union
+        # 2. 深证 union (排除 *_announce_union.parquet, 不同 schema)
         deep = []
         for f in sorted(glob.glob(os.path.join(HIST, "*_union.parquet"))):
+            if f.endswith("_announce_union.parquet"):
+                continue
             d = pd.read_parquet(f)[["index_code", "code", "code_name",
                                     "in_current", "was_removed"]]
             d["source"] = "akshare_cni"