From 0fa8263bf8cdf5b3374a82da1cfbb13e67009042 Mon Sep 17 00:00:00 2001 From: Teknium <127238744+teknium1@users.noreply.github.com> Date: Wed, 2 Sep 2026 23:03:21 -0700 Subject: [PATCH] refactor(agent/conversation_compression): drop pre-return lease releases already covered by the finally --- agent/conversation_compression.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/agent/conversation_compression.py b/agent/conversation_compression.py index f7a6e59f85..db2bb6af00 100644 --- a/agent/conversation_compression.py +++ b/agent/conversation_compression.py @@ -3667,9 +3667,7 @@ def compress_context( agent, compressed, messages, messages_before_compression, attempt_generation=attempt.generation, attempt_started_at=attempt.started_at, ): - _existing_sp = _existing_system_prompt(agent, system_message) - lease.release() - return messages, _existing_sp + return messages, _existing_system_prompt(agent, system_message) if commit_fence is not None: _commit_fence_entered = commit_fence.begin_commit(_hard_cancel_event) @@ -3689,7 +3687,6 @@ def compress_context( agent, attempt.started_at, STALL_INTERRUPTED_FAILURE_CLASS if _stall_backoff else "commit_fence_cancelled", ) - lease.release() return messages, _existing_sp _warn_summary_or_aux_fallback(agent) @@ -3706,7 +3703,6 @@ def compress_context( attempt=attempt, ) if commit.refused_prompt is not None: - lease.release() return messages, commit.refused_prompt compressed = commit.compressed split_status = commit.split_status