diff --git a/tools/process_registry.py b/tools/process_registry.py index 184939adf755..6c96a3dcfde2 100644 --- a/tools/process_registry.py +++ b/tools/process_registry.py @@ -823,7 +823,7 @@ def _move_to_finished(self, session: ProcessSession): # ----- Query Methods ----- def is_completion_consumed(self, session_id: str) -> bool: - """Check if a completion notification was already consumed via wait/poll/log.""" + """Check if a completion notification was already consumed via wait/read_log.""" return session_id in self._completion_consumed def drain_notifications(self) -> "list[tuple[dict, str]]": @@ -949,7 +949,6 @@ def poll(self, session_id: str) -> dict: } if session.exited: result["exit_code"] = session.exit_code - self._completion_consumed.add(session_id) if session.detached: result["detached"] = True result["note"] = "Process recovered after restart -- output history unavailable"