refactor(turn): drop section-banner comments in turn_facade_lease
This commit is contained in:
@@ -42,8 +42,6 @@ class DurableTurnLease:
|
||||
def _current_session_id(self) -> str:
|
||||
return getattr(self.agent, "session_id", None) or self.session_id
|
||||
|
||||
# ── thread construction ──────────────────────────────────────────────────────
|
||||
|
||||
def build_threads(self) -> None:
|
||||
"""Create (not start) the refresher thread and, when configured, the liveness watchdog.
|
||||
|
||||
@@ -76,8 +74,6 @@ class DurableTurnLease:
|
||||
deactivate_turn=self.deactivate_after_liveness_abort,
|
||||
).make_thread()
|
||||
|
||||
# ── lifecycle ────────────────────────────────────────────────────────────────
|
||||
|
||||
def start(self) -> None:
|
||||
with self._lock:
|
||||
self.turn_active = True
|
||||
@@ -113,8 +109,6 @@ class DurableTurnLease:
|
||||
with self._lock:
|
||||
return self.turn_active
|
||||
|
||||
# ── interrupts ───────────────────────────────────────────────────────────────
|
||||
|
||||
def _interrupt_turn(self, message: str) -> None:
|
||||
# Lease-loss interrupts fire UNCONDITIONALLY (no generation claim): a lost lease means this
|
||||
# process no longer owns the session. Only the watchdog's stalls can be spuriously stale.
|
||||
@@ -203,8 +197,6 @@ class DurableTurnLease:
|
||||
with redirect_lock:
|
||||
_clear_if_owned()
|
||||
|
||||
# ── refresher thread body ────────────────────────────────────────────────────
|
||||
|
||||
def refresh_loop(self) -> None:
|
||||
"""Renew the lease every ``refresh_interval``; a miss or error interrupts the turn.
|
||||
|
||||
|
||||
Reference in New Issue
Block a user