fix(ci): align drift baseline store and workflow pin

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

Author: Pigbibi

.github/workflows/drift-check.yml

@@ -14,65 +14,14 @@ permissions:
 
 jobs:
   drift:
-    runs-on: ubuntu-latest
-    timeout-minutes: 15
-    env:
-      FORCE_JAVASCRIPT_ACTIONS_TO_NODE24: "true"
-      STRATEGY_DOMAIN: crypto
-
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v6
-
-      - name: Checkout QuantPlatformKit
-        uses: actions/checkout@v6
-        with:
-          repository: QuantStrategyLab/QuantPlatformKit
-          ref: main
-          path: external/QuantPlatformKit
-
-      - name: Set up Python
-        uses: actions/setup-python@v6
-        with:
-          python-version: "3.11"
-
-      - name: Install dependencies
-        run: |
-          set -euo pipefail
-          python -m pip install --upgrade pip
-          python -m pip install -e . pandas
-          python -m pip install --no-deps -e external/QuantPlatformKit
-
-      - name: Run drift detection
-        run: quant-lifecycle drift --domain crypto --no-alerts
-
-      - name: Sync drift alerts to GitHub Issues
-        env:
-          GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-          GITHUB_REPOSITORY: ${{ github.repository }}
-        run: python scripts/run_drift_github_issues.py
-
-      - name: Checkout AIAuditBridge
-        uses: actions/checkout@v6
-        with:
-          repository: QuantStrategyLab/AIAuditBridge
-          ref: main
-          path: external/AIAuditBridge
-
-      - name: Dual-review critical drift
-        env:
-          AIAUDIT_BRIDGE_ROOT: external/AIAuditBridge
-          CODEX_AUDIT_SERVICE_URL: ${{ secrets.CODEX_AUDIT_SERVICE_URL }}
-          AI_GATEWAY_SERVICE_URL: ${{ vars.AI_GATEWAY_SERVICE_URL }}
-        run: |
-          script="external/AIAuditBridge/scripts/run_drift_dual_review.py"
-          if [ ! -f "$script" ]; then
-            echo "::notice::dual-review scripts unavailable; skipping until AIAuditBridge is merged"
-            exit 0
-          fi
-          if [ -z "${CODEX_AUDIT_SERVICE_URL:-}" ]; then
-            echo "::notice::CODEX_AUDIT_SERVICE_URL not configured; skipping dual-review dispatch"
-            exit 0
-          fi
-          PYTHONPATH=external/AIAuditBridge python "$script" \
-            --domain "${STRATEGY_DOMAIN}" --dispatch
+    uses: QuantStrategyLab/QuantPlatformKit/.github/workflows/reusable-drift-check.yml@335c7a22bc3f570bd5705427ccc40172eda6b289
+    with:
+      strategy_domain: crypto
+      caller_event_name: ${{ github.event_name }}
+      caller_pr_head_repository: ${{ github.event.pull_request.head.repo.full_name || '' }}
+      snapshot_repository: QuantStrategyLab/CryptoLivePoolPipelines
+      snapshot_checkout_path: external/CryptoLivePoolPipelines
+      ai_gateway_service_url: ${{ vars.AI_GATEWAY_SERVICE_URL }}
+    secrets:
+      codex_audit_service_url: ${{ secrets.CODEX_AUDIT_SERVICE_URL }}
+      snapshot_repository_token: ${{ secrets.SNAPSHOT_REPOSITORY_TOKEN }}

scripts/run_walk_forward_backtest.py

@@ -4,7 +4,10 @@
 from __future__ import annotations
 
 import argparse
+import copy
+import hashlib
 import json
+import re
 from datetime import date
 from pathlib import Path
 from typing import Any
@@ -45,6 +48,40 @@ def _result_payload(item: Any) -> dict[str, Any]:
     }
 
 
+def _baseline_param_set_id(profile: str, params: dict[str, Any]) -> str:
+    fingerprint = hashlib.sha256(json.dumps(params, sort_keys=True, default=str).encode("utf-8")).hexdigest()[:12]
+    return f"{profile}_baseline_{fingerprint}"
+
+
+def _current_qpk_pin() -> str:
+    text = (Path(__file__).resolve().parents[1] / "qsl.toml").read_text(encoding="utf-8")
+    match = re.search(r"QuantPlatformKit\.git@([0-9a-f]{40})", text)
+    return match.group(1) if match else "unknown"
+
+
+def _baseline_identity_params(
+    params: dict[str, Any],
+    *,
+    synthetic_days: int,
+    baseline_result: Any,
+) -> dict[str, Any]:
+    identity = copy.deepcopy(params)
+    identity["_baseline_start_date"] = baseline_result.start_date.isoformat() if baseline_result.start_date else None
+    identity["_baseline_end_date"] = baseline_result.end_date.isoformat() if baseline_result.end_date else None
+    identity["_qpk_pin"] = _current_qpk_pin()
+    identity["_synthetic_days"] = synthetic_days
+    return identity
+
+
+def _build_runner(*, profile: str, synthetic_days: int, panel: Any = None, market_history: Any = None):
+    return build_backtest_runner(
+        profile,
+        panel=panel,
+        market_history=market_history,
+        synthetic_days=synthetic_days,
+    )
+
+
 def run_walk_forward(
     *,
     profile: str,
@@ -61,21 +98,43 @@ def run_walk_forward(
         raise ValueError(f"unsupported profile={profile!r}; supported={sorted(SUPPORTED_PROFILES)}")
 
     params = dict(PROFILE_DEFAULTS.get(profile, {"min_history_days": DEFAULT_MIN_HISTORY_DAYS}))
-    runner = build_backtest_runner(
-        profile,
+    store = PerformanceStore(local_root=store_root) if store_root is not None else PerformanceStore.from_env()
+    orchestrator = BacktestOrchestrator(store=store)
+
+    baseline_params = copy.deepcopy(params)
+    runner = _build_runner(
+        profile=profile,
         panel=panel,
         market_history=market_history,
         synthetic_days=synthetic_days,
     )
-    store = PerformanceStore(local_root=store_root or Path("/tmp/crypto_wf_store"))
-    orchestrator = BacktestOrchestrator(store=store)
     orchestrator.register_runner("crypto", runner)
-
-    baseline = runner.run(profile, params)
+    baseline_probe = orchestrator.run(
+        profile,
+        domain="crypto",
+        params=copy.deepcopy(baseline_params),
+        param_set_id="__discarded__",
+        start_date=None,
+        end_date=None,
+    )
+    baseline_store_params = _baseline_identity_params(
+        baseline_params,
+        synthetic_days=synthetic_days,
+        baseline_result=baseline_probe,
+    )
+    baseline = orchestrator.run(
+        profile,
+        domain="crypto",
+        params=baseline_store_params,
+        param_set_id=_baseline_param_set_id(profile, baseline_store_params),
+        start_date=None,
+        end_date=None,
+    )
+    wf_params = copy.deepcopy(params)
     wf_results = orchestrator.walk_forward(
         profile,
         domain="crypto",
-        params=params,
+        params=wf_params,
         windows=windows,
         param_set_id=f"{profile}_wf",
     )

tests/test_drift_workflow_config.py

@@ -0,0 +1,15 @@
+from pathlib import Path
+
+
+def test_drift_workflow_wires_pipeline_repo_and_lifecycle_env() -> None:
+    workflow = (Path(__file__).resolve().parents[1] / ".github" / "workflows" / "drift-check.yml").read_text(encoding="utf-8")
+
+    assert "uses: QuantStrategyLab/QuantPlatformKit/.github/workflows/reusable-drift-check.yml@335c7a22bc3f570bd5705427ccc40172eda6b289" in workflow
+    assert "strategy_domain: crypto" in workflow
+    assert "caller_event_name: ${{ github.event_name }}" in workflow
+    assert "caller_pr_head_repository: ${{ github.event.pull_request.head.repo.full_name || '' }}" in workflow
+    assert "snapshot_repository: QuantStrategyLab/CryptoLivePoolPipelines" in workflow
+    assert "snapshot_checkout_path: external/CryptoLivePoolPipelines" in workflow
+    assert "ai_gateway_service_url: ${{ vars.AI_GATEWAY_SERVICE_URL }}" in workflow
+    assert "codex_audit_service_url: ${{ secrets.CODEX_AUDIT_SERVICE_URL }}" in workflow
+    assert "snapshot_repository_token: ${{ secrets.SNAPSHOT_REPOSITORY_TOKEN }}" in workflow

tests/test_run_walk_forward_backtest.py

@@ -0,0 +1,35 @@
+from __future__ import annotations
+
+import json
+import sys
+from pathlib import Path
+
+ROOT = Path(__file__).resolve().parents[1]
+SRC = ROOT / "src"
+QPK_SRC = ROOT.parent / "QuantPlatformKit" / "src"
+if str(QPK_SRC) not in sys.path:
+    sys.path.insert(0, str(QPK_SRC))
+if str(SRC) not in sys.path:
+    sys.path.insert(0, str(SRC))
+
+from scripts.run_walk_forward_backtest import run_walk_forward
+
+
+def test_run_walk_forward_persists_lifecycle_baseline(tmp_path: Path) -> None:
+    payload = run_walk_forward(
+        profile="crypto_live_pool_rotation",
+        synthetic_days=2200,
+        store_root=tmp_path,
+    )
+
+    records = [
+        json.loads(path.read_text(encoding="utf-8"))
+        for path in (tmp_path / "backtest" / "crypto" / "crypto_live_pool_rotation").glob("*.json")
+    ]
+
+    assert payload["baseline"]["sharpe_ratio"] is not None
+    baseline_records = [record for record in records if "_baseline_" in record["param_set_id"]]
+    assert baseline_records
+    assert baseline_records[-1]["params"]["_qpk_pin"]
+    assert baseline_records[-1]["params"]["_baseline_end_date"]
+    assert any("_wf" in record["param_set_id"] for record in records)