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

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

Author: Pigbibi

.github/workflows/drift-check.yml

@@ -14,7 +14,7 @@ permissions:
 
 jobs:
   drift:
-    uses: QuantStrategyLab/QuantPlatformKit/.github/workflows/reusable-drift-check.yml@6ad21ccbaf176f9526a417f7df0716ba27eb43b6
+    uses: QuantStrategyLab/QuantPlatformKit/.github/workflows/reusable-drift-check.yml@335c7a22bc3f570bd5705427ccc40172eda6b289
     with:
       strategy_domain: crypto
       caller_event_name: ${{ github.event_name }}

scripts/run_walk_forward_backtest.py

@@ -5,8 +5,9 @@
 
 import argparse
 import copy
-import json
 import hashlib
+import json
+import re
 from datetime import date
 from pathlib import Path
 from typing import Any
@@ -52,6 +53,26 @@ def _baseline_param_set_id(profile: str, params: dict[str, Any]) -> str:
     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,
@@ -77,37 +98,38 @@ 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}))
-    store = PerformanceStore(local_root=store_root or Path("/tmp/crypto_wf_store"))
+    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)
-    baseline_store_params = copy.deepcopy(baseline_params)
-    baseline_runner = _build_runner(
+    runner = _build_runner(
         profile=profile,
         panel=panel,
         market_history=market_history,
         synthetic_days=synthetic_days,
     )
-    baseline_raw = baseline_runner.run(
+    orchestrator.register_runner("crypto", runner)
+    baseline_probe = orchestrator.run(
         profile,
-        baseline_params,
+        domain="crypto",
+        params=copy.deepcopy(baseline_params),
+        param_set_id="__discarded__",
         start_date=None,
         end_date=None,
     )
-    baseline = orchestrator.persist_result(
-        baseline_raw,
-        strategy_profile=profile,
+    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,
     )
-    runner = _build_runner(
-        profile=profile,
-        panel=panel,
-        market_history=market_history,
-        synthetic_days=synthetic_days,
-    )
-    orchestrator.register_runner("crypto", runner)
     wf_params = copy.deepcopy(params)
     wf_results = orchestrator.walk_forward(
         profile,

tests/test_drift_workflow_config.py

@@ -4,7 +4,7 @@
 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@6ad21ccbaf176f9526a417f7df0716ba27eb43b6" in workflow
+    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

tests/test_run_walk_forward_backtest.py

@@ -28,5 +28,8 @@ def test_run_walk_forward_persists_lifecycle_baseline(tmp_path: Path) -> None:
     ]
 
     assert payload["baseline"]["sharpe_ratio"] is not None
-    assert any("_baseline_" in record["param_set_id"] for record in records)
+    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)