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

blackout: enforce bounded oldest-drop queue policy on overflow (#371) #384

Merged
jihoson merged 2 commits from feature/issue-371-blackout-queue-overflow into feature/v3-session-policy-stream 2026-03-02 03:07:12 +09:00
Conversation 2 Commits 2 Files Changed 6 +3 -13
2 changed files with 3 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 96e5de7c5d - Show all commits

15
src/main.py
View File

@@ -1031,19 +1031,10 @@ def _maybe_queue_order_intent(
price: float,
source: str,
) -> bool:
def _coerce_nonnegative_int(value: Any) -> int:
try:
parsed = int(value)
except (TypeError, ValueError):
return 0
return max(0, parsed)
if not BLACKOUT_ORDER_MANAGER.in_blackout():
return False
before_overflow_drops = _coerce_nonnegative_int(
getattr(BLACKOUT_ORDER_MANAGER, "overflow_drop_count", 0)
)
before_overflow_drops = BLACKOUT_ORDER_MANAGER.overflow_drop_count
queued = BLACKOUT_ORDER_MANAGER.enqueue(
_build_queued_order_intent(
market=market,
@@ -1055,9 +1046,7 @@ def _maybe_queue_order_intent(
)
)
if queued:
after_overflow_drops = _coerce_nonnegative_int(
getattr(BLACKOUT_ORDER_MANAGER, "overflow_drop_count", 0)
)
after_overflow_drops = BLACKOUT_ORDER_MANAGER.overflow_drop_count
logger.warning(
(
"Blackout active: queued order intent %s %s (%s) "

1
tests/test_main.py
View File

@@ -6502,6 +6502,7 @@ async def test_blackout_queues_order_and_skips_submission() -> None:
blackout_manager.in_blackout.return_value = True
blackout_manager.enqueue.return_value = True
blackout_manager.pending_count = 1
blackout_manager.overflow_drop_count = 0
with patch("src.main.BLACKOUT_ORDER_MANAGER", blackout_manager):
await trading_cycle(