mirrors/hermes-agent
1
0
Fork 0
mirror of https://github.com/NousResearch/hermes-agent.git synced 2026-07-01 12:02:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

fix(agent): keep unbound compressors on the fail-open path (#54465)

Browse source
This commit is contained in:
Rod Boev 2026-06-28 20:42:57 -04:00 • committed by kshitij
parent 6fd701acbe
commit 7479f26b3f
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
agent/context_compressor.py
View file

@ -672,7 +672,7 @@ class ContextCompressor(ContextEngine):
def on_session_start(self, session_id: str, **kwargs) -> None:
"""Bind session-scoped compression state for a new or resumed session."""
super().on_session_start(session_id, **kwargs)
self.bind_session_state(kwargs.get("session_db", self._session_db), session_id)
self.bind_session_state(kwargs.get("session_db", getattr(self, "_session_db", None)), session_id)
def get_active_compression_failure_cooldown(self) -> Optional[Dict[str, Any]]:
"""Return the live compression-failure cooldown for the bound session."""
@ -686,8 +686,8 @@ class ContextCompressor(ContextEngine):
"error": self._last_summary_error,
}
session_db = self._session_db
session_id = self._session_id
session_db = getattr(self, "_session_db", None)
session_id = getattr(self, "_session_id", "")
if not session_db or not session_id:
return None
@ -725,8 +725,8 @@ class ContextCompressor(ContextEngine):
self._summary_failure_cooldown_until = time.monotonic() + cooldown_seconds
self._last_summary_error = error
session_db = self._session_db
session_id = self._session_id
session_db = getattr(self, "_session_db", None)
session_id = getattr(self, "_session_id", "")
if not session_db or not session_id:
return
@ -744,8 +744,8 @@ class ContextCompressor(ContextEngine):
self._summary_failure_cooldown_until = 0.0
self._last_summary_error = None
session_db = self._session_db
session_id = self._session_id
session_db = getattr(self, "_session_db", None)
session_id = getattr(self, "_session_id", "")
if not session_db or not session_id:
return