jihoson/The-Ouroboros
0
0
Fork 0
Code Issues 5 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

blackout: simplify recovery session_id binding to queued value

Browse Source
This commit is contained in:
agentson
2026-03-02 03:16:55 +09:00
parent 1d404975ea
commit c967ae6715
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main.py
View File

@@ -1115,7 +1115,6 @@ async def process_blackout_recovery_orders(
accepted = result.get("rt_cd", "0") == "0" accepted = result.get("rt_cd", "0") == "0"
if accepted: if accepted:
runtime_session_id = get_session_info(market).session_id
log_trade( log_trade(
conn=db_conn, conn=db_conn,
stock_code=intent.stock_code, stock_code=intent.stock_code,
@@ -1127,7 +1126,7 @@ async def process_blackout_recovery_orders(
pnl=0.0, pnl=0.0,
market=market.code, market=market.code,
exchange_code=market.exchange_code, exchange_code=market.exchange_code,
session_id=runtime_session_id, session_id=intent.session_id,
) )
logger.info( logger.info(
"Recovered queued order executed: %s %s (%s) qty=%d price=%.4f source=%s", "Recovered queued order executed: %s %s (%s) qty=%d price=%.4f source=%s",

3
tests/test_main.py
View File

@@ -6525,6 +6525,7 @@ async def test_process_blackout_recovery_executes_valid_intents() -> None:
intent.quantity = 1 intent.quantity = 1
intent.price = 100.0 intent.price = 100.0
intent.source = "test" intent.source = "test"
intent.session_id = "NXT_AFTER"
intent.attempts = 0 intent.attempts = 0
blackout_manager = MagicMock() blackout_manager = MagicMock()
@@ -6555,7 +6556,7 @@ async def test_process_blackout_recovery_executes_valid_intents() -> None:
assert row is not None assert row is not None
assert row[0] == "BUY" assert row[0] == "BUY"
assert row[1] == 1 assert row[1] == 1
assert row[2] == "KRX_REG" assert row[2] == "NXT_AFTER"
assert row[3].startswith("[blackout-recovery]") assert row[3].startswith("[blackout-recovery]")