External/roboco
1
0
Fork 0
mirror of https://github.com/rennf93/roboco.git synced 2026-08-03 07:23:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor(orchestrator): extract crash-retry/escalate from _handle_stopped_container

Browse Source 
_handle_stopped_container reached cyclomatic rank C (11) after the provider-overload parking branch was added, failing the xenon --max-absolute B gate on master. Extract the crash-retry-or-escalate tail into _crash_retry_or_escalate — a pure move, no behaviour change — dropping the method back under the threshold. Covered by the existing stopped-container tests (graceful exit, grok 429 park, overload park, crash-retry, escalate).
This commit is contained in:
Renn F
2026-06-22 13:15:52 +02:00
parent 34ae9fc31b
commit 87fdf59757
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
roboco/runtime/orchestrator.py
+8
View File
@@ -5145,6 +5145,14 @@ Start by:
if graceful: if graceful:
instance.error_count = 0 instance.error_count = 0
return return
await self._crash_retry_or_escalate(agent_id, instance)
async def _crash_retry_or_escalate(self, agent_id: str, instance: Any) -> None:
"""A crashed (non-graceful) agent: auto-restart up to a cap, then escalate.
Bumps error_count and respawns while under the cap; at exactly the cap
escalates once to humans (subsequent crashes stay quiet to avoid spam).
"""
instance.error_count += 1 instance.error_count += 1
max_retries = 3 max_retries = 3
if instance.error_count < max_retries: if instance.error_count < max_retries: