fix(core-runtime): align local backtest with clean Core and stabilize run loop

.github/argo-launchers/run-backtest.yaml

@@ -12,6 +12,6 @@ spec:
       - name: image_tag
         value: "${IMAGE_TAG}"
       - name: experiment_config
-        value: "/usr/local/lib/python3.11/site-packages/core_runtime/argo/argo.json"
+        value: "/usr/local/lib/python3.11/site-packages/core_runtime/argo/bt_config_argo.json"
       - name: scratch_root
         value: "/mnt/scratch"

README.md

@@ -48,7 +48,7 @@ Order, State, or Risk Engine.
 Current local smoke is usable from the `core-runtime` repository root:
 
 ```bash
-python -m core_runtime.local.backtest --config core_runtime/local/local.json
+python -m core_runtime.local.backtest --config core_runtime/local/bt_config_local.json
 ```
 
 Default output location:
@@ -67,14 +67,7 @@ From the `core-runtime` repository root:
 
 ```bash
 python -m pip install -e .
-python -m core_runtime.local.backtest --config core_runtime/local/local.json
-```
-
-If `tradingchassis_core` is not already resolvable in your environment, install `core` as a
-sibling editable package in a monorepo workspace:
-
-```bash
-python -m pip install -e ../core
+python -m core_runtime.local.backtest --config core_runtime/local/bt_config_local.json
 ```
 
 ---
@@ -83,8 +76,8 @@ python -m pip install -e ../core
 
 | Mode | Entrypoint | Command shape | Notes |
 | --- | --- | --- | --- |
-| Local backtest | `core_runtime/local/backtest.py` | `python -m core_runtime.local.backtest --config core_runtime/local/local.json` | Main local runner. |
-| Argo plan/run orchestration | `core_runtime/backtest/runtime/entrypoint.py` | `python -m core_runtime.backtest.runtime.entrypoint --config core_runtime/argo/argo.json --plan` | Planner and sweep-context emitter for Argo flow. |
+| Local backtest | `core_runtime/local/backtest.py` | `python -m core_runtime.local.backtest --config core_runtime/local/bt_config_local.json` | Main local runner. |
+| Argo plan/run orchestration | `core_runtime/backtest/runtime/entrypoint.py` | `python -m core_runtime.backtest.runtime.entrypoint --config core_runtime/argo/bt_config_argo.json --plan` | Planner and sweep-context emitter for Argo flow. |
 | Sweep worker | `core_runtime/backtest/runtime/run_sweep.py` | `python -m core_runtime.backtest.runtime.run_sweep --context <path-to-sweep-json>` | Executes one sweep context. |
 
 ---
@@ -94,7 +87,7 @@ python -m pip install -e ../core
 | Capability area | Status | Notes |
 | --- | --- | --- |
 | Canonical runtime paths | Active | `MarketEvent`, `OrderSubmittedEvent`, `ControlTimeEvent` |
-| Compatibility paths | Active | Post-submission order/fill progression via snapshots, `OrderStateEvent`, and `DerivedFillEvent` |
+| Runtime-local compatibility handling | Active | Raw venue order snapshots stay in runtime bookkeeping; Core receives canonical `OrderExecutionFeedbackEvent` (account-level only). |
 | Deferred capabilities | Deferred | Runtime `FillEvent` ingress, `ExecutionFeedbackRecordSource`, replay/storage/Event Stream persistence, `ProcessingContext` |
 
 ---
@@ -115,11 +108,11 @@ python -m pip install -e ../core
 
 ---
 
-## Compatibility paths
+## Runtime-local compatibility handling
 
-- snapshot-based post-submission progression
-- `OrderStateEvent`
-- `DerivedFillEvent`
+- snapshot-based post-submission bookkeeping remains runtime-local
+- Core ingestion uses account-level `OrderExecutionFeedbackEvent`
+- no snapshot row payload is pushed into Core
 
 ---
 
@@ -160,7 +153,7 @@ tests/                      Runtime tests and deterministic fixtures
 
 Primary local config:
 
-- `core_runtime/local/local.json`
+- `core_runtime/local/bt_config_local.json`
 - OCI config template (for local object storage auth setups): `core_runtime/local/oci.config.example`
 
 Note: local JSON configs use cwd-relative paths for `tests/data/...` inputs and `.runtime/...`

argo/templates/workflowtemplate-backtest-fanout.yaml

@@ -24,7 +24,7 @@ spec:
 
       - name: experiment_config
         description: "Path to experiment JSON inside the container"
-        value: /usr/local/lib/python3.11/site-packages/core_runtime/argo/argo.json
+        value: /usr/local/lib/python3.11/site-packages/core_runtime/argo/bt_config_argo.json
 
       - name: scratch_root
         description: "Scratch root inside the container"

core_runtime/backtest/adapters/protocols.py

@@ -74,6 +74,23 @@ def read_orders_snapshot(self) -> tuple[Any, Any]:
         """Return (state_values, orders) from current snapshot boundary."""
 
 
+class VenueAdapter(
+    VenueEventWaiter,
+    VenueClock,
+    MarketInputSource,
+    OrderSnapshotSource,
+    Protocol,
+):
+    """Composite runtime venue adapter contract for strategy runner."""
+
+    def record(self, recorder: Any) -> bool:
+        """Persist current simulation state.
+
+        Returns:
+            True when recorder capacity is exhausted and no record was written.
+        """
+
+
 class OrderSubmissionGateway(Protocol):
     """Outbound order command submission capability.
 

core_runtime/backtest/adapters/venue.py

@@ -8,7 +8,7 @@
 if TYPE_CHECKING:
     from hftbacktest import ROIVectorMarketDepthBacktest
 
-from tradingchassis_core.core.ports.venue_adapter import VenueAdapter
+from core_runtime.backtest.adapters.protocols import VenueAdapter
 
 
 @dataclass(frozen=True)
@@ -43,7 +43,14 @@ def read_orders_snapshot(self) -> tuple[Any, Any]:
             self.hbt.orders(self.asset_no),
         )
 
-    def record(self, recorder: Any) -> None:
+    def record(self, recorder: Any) -> bool:
         """Record the current backtest state using the given recorder."""
         # hftbacktest recorder is a thin wrapper exposing .recorder.record(hbt).
-        recorder.recorder.record(self.hbt)
+        try:
+            recorder.recorder.record(self.hbt)
+        except IndexError:
+            # hftbacktest Recorder has a fixed capacity and raises IndexError
+            # when the record buffer is exhausted. Runtime treats this as
+            # recording exhaustion and keeps the backtest loop alive.
+            return True
+        return False

core_runtime/backtest/engine/event_stream_cursor.py

@@ -20,6 +20,14 @@ def next_index(self) -> int:
     def attempt_position(self) -> ProcessingPosition:
         return ProcessingPosition(index=self._next_index)
 
+    def attempt_positions(self, count: int) -> tuple[ProcessingPosition, ...]:
+        if count < 0:
+            raise ValueError("count must be >= 0")
+        return tuple(
+            ProcessingPosition(index=self._next_index + offset)
+            for offset in range(count)
+        )
+
     def commit_success(self, position: ProcessingPosition) -> None:
         if position.index != self._next_index:
             raise ValueError(

core_runtime/backtest/engine/hft_engine.py

@@ -4,21 +4,12 @@
 
 import importlib
 from dataclasses import dataclass
-from typing import TYPE_CHECKING
-
-from hftbacktest import (
-    BacktestAsset,
-    Recorder,
-    ROIVectorMarketDepthBacktest,
-)
+from typing import TYPE_CHECKING, Any
 
 if TYPE_CHECKING:
     from tradingchassis_core.core.domain.configuration import CoreConfiguration
     from tradingchassis_core.core.risk.risk_config import RiskConfig
 
-from tradingchassis_core.strategies.base import Strategy
-from tradingchassis_core.strategies.strategy_config import StrategyConfig
-
 from core_runtime.backtest.adapters.execution import HftBacktestExecutionAdapter
 from core_runtime.backtest.adapters.venue import HftBacktestVenueAdapter
 from core_runtime.backtest.engine.engine_base import (
@@ -27,6 +18,7 @@
     BacktestResult,
 )
 from core_runtime.backtest.engine.strategy_runner import HftStrategyRunner
+from core_runtime.backtest.strategy_api import Strategy, StrategyConfig
 
 
 # pylint: disable=too-many-instance-attributes
@@ -81,8 +73,10 @@ class HftBacktestConfig(BacktestConfig):
     core_cfg: CoreConfiguration
 
 
-def _build_backtester(engine_cfg: HftEngineConfig) -> ROIVectorMarketDepthBacktest:
+def _build_backtester(engine_cfg: HftEngineConfig) -> Any:
     """Create an ROIVectorMarketDepthBacktest from the engine configuration."""
+    from hftbacktest import BacktestAsset, ROIVectorMarketDepthBacktest
+
     asset = BacktestAsset()
 
     # For now we assume file paths. Later this can be replaced with an S3 resolver.
@@ -126,10 +120,13 @@ def _load_strategy_class(self, class_path: str) -> type[Strategy]:
         module_path, class_name = class_path.split(":")
         module = importlib.import_module(module_path)
         cls = getattr(module, class_name)
-
-        if not issubclass(cls, Strategy):
+        if not callable(getattr(cls, "on_feed", None)):
+            raise TypeError(
+                f"Loaded class {class_name} does not implement on_feed."
+            )
+        if not callable(getattr(cls, "on_order_update", None)):
             raise TypeError(
-                f"Loaded class {class_name} is not a subclass of Strategy."
+                f"Loaded class {class_name} does not implement on_order_update."
             )
 
         return cls
@@ -150,6 +147,8 @@ def run(self) -> BacktestResult:
         hbt = _build_backtester(engine_cfg)
 
         # 2) Prepare recorder (single asset, record every step)
+        from hftbacktest import Recorder
+
         recorder = Recorder(1, engine_cfg.max_steps)
 
         # 3) Build strategy and runner
@@ -182,6 +181,6 @@ def run(self) -> BacktestResult:
                 "strategy_name": strategy_cfg.class_path,
                 "strategy_params": strategy_cfg.params,
                 "risk_scope": risk_cfg.scope,
-                "risk_params": risk_cfg.params,
+                "risk_params": risk_cfg.model_dump(),
             },
         )