feat: support accepted baseline drift stores

Co-Authored-By: Codex <noreply@openai.com>

Author: Pigbibi

src/quant_platform_kit/strategy_lifecycle/cli.py

@@ -39,7 +39,17 @@ def _run_drift(args: argparse.Namespace) -> int:
         "quant_platform_kit.strategy_lifecycle.drift_detector",
         "run_drift_detection",
     )
-    results = run_drift_detection(domain=args.domain, strategy_profile=args.strategy)
+    baseline_store = None
+    if getattr(args, "baseline_local_root", None):
+        from pathlib import Path
+        from quant_platform_kit.strategy_lifecycle.performance_store import PerformanceStore
+
+        baseline_store = PerformanceStore(local_root=Path(args.baseline_local_root))
+    results = run_drift_detection(
+        domain=args.domain,
+        strategy_profile=args.strategy,
+        baseline_store=baseline_store,
+    )
     critical_count = sum(1 for item in results if getattr(getattr(item, "status", None), "value", None) == "critical")
     review_count = sum(1 for item in results if getattr(getattr(item, "status", None), "value", None) == "review")
     _print(f"[drift] {len(results)} strategies checked, {critical_count} critical, {review_count} review")
@@ -233,6 +243,7 @@ def build_parser() -> argparse.ArgumentParser:
     drift.add_argument("--strategy", default=None)
     drift.add_argument("--no-alerts", action="store_true")
     drift.add_argument("--dry-run-alerts", action="store_true")
+    drift.add_argument("--baseline-local-root", default=None)
     drift.set_defaults(func=_run_drift)
 
     optimize = subparsers.add_parser("optimize", help="Run parameter optimization for one strategy.")

src/quant_platform_kit/strategy_lifecycle/drift_detector.py

@@ -134,9 +134,11 @@ def run_drift_detection(
     policy: DriftPolicy | None = None,
     fail_on_empty: bool = True,
     store: PerformanceStore | None = None,
+    baseline_store: PerformanceStore | None = None,
 ) -> list[DriftResult]:
-    """Run drift detection for all strategies in a domain."""
+    """Run drift detection, optionally reading accepted baselines from another store."""
     store = store or PerformanceStore.from_env()
+    baseline_store = baseline_store or store
     policy = policy or DriftPolicy.load_default()
 
     from quant_platform_kit.strategy_lifecycle.return_collector import ReturnCollector
@@ -158,7 +160,7 @@ def run_drift_detection(
         if snapshot is None:
             missing_snapshots += 1
             continue
-        backtest = store.load_latest_backtest(domain, profile)
+        backtest = baseline_store.load_latest_backtest(domain, profile)
         previous = store.load_latest_drift(domain, profile)
         result = detect_drift(snapshot, backtest=backtest, policy=policy,
                               previous_status=previous.status if previous else None)