fix: preserve independent lifecycle baselines

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

Author: Pigbibi

scripts/run_walk_forward_backtest.py

@@ -47,10 +47,9 @@ def _result_payload(item: Any) -> dict[str, Any]:
     }
 
 
-def _baseline_param_set_id(profile: str, params: dict[str, Any], *, provenance: str | None = None) -> str:
+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]
-    suffix = hashlib.sha256(str(provenance or "unknown").encode("utf-8")).hexdigest()[:8]
-    return f"{profile}_baseline_{fingerprint}_{suffix}"
+    return f"{profile}_baseline_{fingerprint}"
 
 
 def _build_runner(*, profile: str, synthetic_days: int, panel: Any = None, market_history: Any = None):
@@ -78,24 +77,37 @@ 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"))
+    orchestrator = BacktestOrchestrator(store=store)
+
+    baseline_params = copy.deepcopy(params)
+    baseline_store_params = copy.deepcopy(baseline_params)
     baseline_runner = _build_runner(
         profile=profile,
         panel=panel,
         market_history=market_history,
         synthetic_days=synthetic_days,
     )
+    baseline_raw = baseline_runner.run(
+        profile,
+        baseline_params,
+        start_date=None,
+        end_date=None,
+    )
+    baseline = orchestrator.persist_result(
+        baseline_raw,
+        strategy_profile=profile,
+        domain="crypto",
+        params=baseline_store_params,
+        param_set_id=_baseline_param_set_id(profile, baseline_store_params),
+    )
     runner = _build_runner(
         profile=profile,
-        panel=copy.deepcopy(panel),
-        market_history=copy.deepcopy(market_history),
+        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_params = copy.deepcopy(params)
-    baseline_raw = baseline_runner.run(profile, baseline_params)
     wf_params = copy.deepcopy(params)
     wf_results = orchestrator.walk_forward(
         profile,
@@ -104,13 +116,6 @@ def run_walk_forward(
         windows=windows,
         param_set_id=f"{profile}_wf",
     )
-    baseline = orchestrator.persist_result(
-        baseline_raw,
-        strategy_profile=profile,
-        domain="crypto",
-        params=baseline_params,
-        param_set_id=_baseline_param_set_id(profile, baseline_params, provenance=getattr(baseline_raw, "run_id", None) or getattr(baseline_raw, "computed_at", None)),
-    )
     return {
         "strategy_profile": profile,
         "domain": "crypto",

tests/test_run_walk_forward_backtest.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+import json
 import sys
 from pathlib import Path
 
@@ -11,23 +12,21 @@
 if str(SRC) not in sys.path:
     sys.path.insert(0, str(SRC))
 
-from quant_platform_kit.strategy_lifecycle.performance_store import PerformanceStore
 from scripts.run_walk_forward_backtest import run_walk_forward
 
 
-def test_run_walk_forward_persists_latest_backtest(tmp_path: Path) -> None:
+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,
     )
 
-    store = PerformanceStore(local_root=tmp_path)
-    backtest = store.load_latest_backtest("crypto", "crypto_live_pool_rotation")
+    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
-    assert payload["baseline"]["run_id"] is not None
-    assert backtest is not None
-    assert backtest.strategy_profile == "crypto_live_pool_rotation"
-    assert "_baseline_" in backtest.param_set_id
-    assert not backtest.param_set_id.endswith("_unknown")
+    assert any("_baseline_" in record["param_set_id"] for record in records)
+    assert any("_wf" in record["param_set_id"] for record in records)