github/AutoGPT
1
1
Fork 0
mirror of https://github.com/Significant-Gravitas/AutoGPT.git synced 2026-04-30 03:00:41 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(copilot): clean up stream registry on enqueue failure in auto-approve

Browse Source 
If enqueue_copilot_turn failed after stream_registry.create_session, the
session was left in "running" state in Redis — locking the session until
the TTL expired. Now calls mark_session_completed on failure so the
session is released immediately.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
anvyle
2026-04-15 20:19:03 +02:00
parent 35bca7c7ad
commit 420251ca9d
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
autogpt_platform/backend/backend/copilot/tools/decompose_goal.py
View File

@@ -119,13 +119,21 @@ async def _run_auto_approve(
tool_name="chat",
turn_id=turn_id,
)
await enqueue_copilot_turn(
session_id=session_id,
user_id=user_id,
message=AUTO_APPROVE_MESSAGE,
turn_id=turn_id,
is_user_message=True,
)
try:
await enqueue_copilot_turn(
session_id=session_id,
user_id=user_id,
message=AUTO_APPROVE_MESSAGE,
turn_id=turn_id,
is_user_message=True,
)
except Exception:
# If enqueueing fails, mark the session completed so it doesn't
# stay stuck in "running" state in the stream registry forever.
await stream_registry.mark_session_completed(
session_id, error_message="Auto-approve enqueue failed"
)
raise
logger.info("decompose_goal auto-approve fired for session %s", session_id)
except asyncio.CancelledError:
raise