| @pytest.mark.unit
|
| def test_sim_exit_consult_uses_the_same_live_gate_and_is_wired_into_the_matrix():
|
| """SOURCE parity: the sim exit rides the SAME consult_mktstate_exit the live sleeve uses (no re-implement),
|
| and the matrix CLI wires it ON by default with a --no-llm-exit ablation."""
|
| root = Path(__file__).resolve().parents[2] / "rtrader"
|
| cel_src = (root / "services" / "combined_engine_live.py").read_text()
|
| cli_src = (root / "cli" / "market_turn_cli.py").read_text()
|
| eng_src = (root / "services" / "signal_sim_engine.py").read_text()
|
| assert "class ExitConsultDecider" in cel_src
|
| assert "consult_mktstate_exit" in cel_src, "sim exit must reuse the live gate, not re-implement it"
|
| assert "consult_liquidation_exit" in cel_src, "liquidation exit must reuse ITS live gate (consolidation)"
|
| > assert "def decide_exit" in eng_src and "next_exit_after" in eng_src # the symmetric seam + re-arm
|
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
|
| E assert ('def decide_exit' in '"""Event-driven, signal-agnostic SIMULATION ENGINE for the market-turn ETF sleeve (bug 45bb285d6a, task #13).\n\nDESIGN OF RECORD (operator 2026-07-11, bug 45bb285d6a): the combined multi-signal simulation — and the live\nsystem it mirrors — MUST be a STATE-MACHINE, EVENT-DRIVEN engine, otherwise it cannot handle the complexity of\ninteracting signals. This module is that engine. It SUPERSEDES the liquidation-only / day-bucket v3 sim (bug\nd372812a68 / task #15): all prior liquidation P&L numbers were liquidation-in-isolation (they ignored the\nrollover up/down state entirely) and are NOT combined-engine numbers.\n\nWHY A NEW MODULE (EXTEND-NEVER-REINVENT justification): no existing framework is a signal-AGNOSTIC,\nevent-time-ordered POSITION state machine that COMBINES arbitrary entry/exit signal sources with directional\nfirst-to-fire exits + owner-aware flips + a per-signal enable/disable knob. The closest existing pieces are:\n``market_turn_bus`` (a LIVE pub/sub dispatch bus over a durable Mongo queue — dispatches ACTIONS live, it does\nnot hold a {direction, owning_signal} position or run a backtest clock); ``market_turn_window_sim`` (a\nrollover-ONLY account-MTM window sim...: best,\n "git_sha": _git_sha(),\n "generated_at": datetime.now(UTC),\n }\n if store and rows:\n _store_oos_monitor(summary, mongo=mongo, db_factory=db_factory)\n return summary\n\n\ndef _store_oos_monitor(summary: Dict[str, Any], *, mongo: Any = None,\n db_factory: Optional[Callable] = None) -> None:\n """Upsert ONE monitor doc per (run_id, in_sample_year). Re-running the monitor refreshes the verdict\n in place rather than growing a pile of near-identical docs."""\n from rtrader.services.liquidation_reverse_buy_executor import _close_db, _open_db\n\n own = mongo is None and db_factory is None\n db = mongo if mongo is not None else (db_factory() if db_factory is not None else _open_db())\n try:\n _coll(db, SIGNAL_SIM_OOS_MONITOR).update_one(\n {"run_id": summary["run_id"], "in_sample_year": summary["in_sample_year"]},\n {"$set": {**summary, "updated_at": datetime.now(UTC)},\n "$setOnInsert": {"created_at": datetime.now(UTC)}}, upsert=True)\n except Exception as exc:\n sentry_sdk.capture_exception(exc)\n finally:\n if own:\n _close_db(db)\n')
|
|
|
| ../robinhood-pm-31888206fa38/tests/services/test_backtest_live_parity.py:714: AssertionError
|