From 5c99dbbd804cb326580b60af632845975f40c614 Mon Sep 17 00:00:00 2001 From: haikdc Date: Sun, 14 Jun 2026 00:05:55 -0700 Subject: [PATCH] =?UTF-8?q?[haik]:=20stop=20importing=20TERMINAL=5FSTATUSE?= =?UTF-8?q?S=20from=20seq=5Flog.py=20and=20define=20it=20as=20a=20local=20?= =?UTF-8?q?constant=20in=20ws=5Fmanager.py=20=E2=80=94=20seq=5Flog=20renam?= =?UTF-8?q?ed=20it=20to=20P=5FTERMINAL=5FSTATUSES=20(private),=20so=20ws?= =?UTF-8?q?=5Fmanager=20now=20owns=20its=20own=20copy=20to=20avoid=20a=20c?= =?UTF-8?q?ross-module=20coupling=20on=20session=20lifecycle=20states?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/apps/agents/core/seq_log.py | 2 -- backend/apps/agents/core/ws_manager.py | 4 +++- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/backend/apps/agents/core/seq_log.py b/backend/apps/agents/core/seq_log.py index 092f45e2..be55b64c 100644 --- a/backend/apps/agents/core/seq_log.py +++ b/backend/apps/agents/core/seq_log.py @@ -15,8 +15,6 @@ logger = logging.getLogger(__name__) # 500 events covers a 30s drop even at ~20Hz thinking deltas (~50KB/session). P_BUFFER_LIMIT = 500 -P_TERMINAL_STATUSES = {"completed", "stopped", "error"} - class P_SessionSeqLog: """Per-session lock + monotonic seq + recent-event ring buffer.""" diff --git a/backend/apps/agents/core/ws_manager.py b/backend/apps/agents/core/ws_manager.py index 12501fb8..a0891854 100644 --- a/backend/apps/agents/core/ws_manager.py +++ b/backend/apps/agents/core/ws_manager.py @@ -3,7 +3,9 @@ import json import logging from fastapi import WebSocket -from backend.apps.agents.core.seq_log import TERMINAL_STATUSES, SEQ_LOG +from backend.apps.agents.core.seq_log import SEQ_LOG + +TERMINAL_STATUSES = {"completed", "stopped", "error"} logger = logging.getLogger(__name__)