feat: Wire ValidatedProvider into main pipeline

Changes:
- _load_data() now wraps provider in ValidatedProvider when
  config.data.validated = True
- Falls back gracefully if secondary provider (adata) unavailable
- Config: config.data.validated (bool, default false)
- Schema: DataConfig.validated field added

Usage:
  config/default.yaml → data.validated: true
  # Pipeline auto-creates ValidatedProvider(primary + adata)

1192 passed (all existing)

Author: sijie-Z

config/default.yaml

@@ -11,6 +11,7 @@ universe:
 # --- Data ---
 data:
   provider: "synthetic"    # synthetic, tushare, baostock, postgres
+  validated: false     # Cross-source validation (requires 2+ providers)
   synthetic:
     embedded_alpha: false  # false=pure noise for research; true=embedded patterns for demo
   start_date: "2021-01-01"

config/schema.py

@@ -17,7 +17,8 @@ class SyntheticConfig:
 
 @dataclass
 class DataConfig:
-    provider: str = "baostock"  # synthetic, baostock, tushare, postgres
+    provider: str = "baostock"
+    validated: bool = False  # synthetic, baostock, tushare, postgres
     synthetic: SyntheticConfig = field(default_factory=SyntheticConfig)
     start_date: str = "2021-01-01"
     end_date: str = "2025-12-31"

main.py

@@ -93,6 +93,25 @@ def _load_data(config, use_tushare: bool = True, use_baostock: bool = False):
             embedded_alpha=embedded,
         )
 
+    # Optional: wrap in ValidatedProvider for cross-source validation
+    validated = getattr(config.data, 'validated', False)
+    if validated and configured_provider != "synthetic":
+        try:
+            from quant_platform.data.providers.adata_provider import AdataProvider
+            from quant_platform.data.providers.validated_provider import ValidatedProvider
+
+            secondary = AdataProvider()
+            # Quick test if adata works
+            _ = secondary.get_metadata()
+
+            provider = ValidatedProvider(
+                providers={"primary": provider, "secondary": secondary},
+                primary="primary",
+            )
+            logger.info("Multi-source validation enabled: primary + adata")
+        except Exception:
+            logger.info("Secondary provider (adata) unavailable — running without validation")
+
     pipeline = DataPipeline(
         provider=provider,
         start_date=config.data.start_date,