fix(chat): retry released queue inputs - #2137
Merged
Merged
Conversation
Contributor
|
No actionable comments were generated in the recent review. 🎉 ℹ️ Recent review info⚙️ Run configurationConfiguration used: defaults Review profile: CHILL Plan: Pro Plus Run ID: 📒 Files selected for processing (12)
💤 Files with no reviewable changes (1)
🚧 Files skipped from review as they are similar to previous changes (3)
📝 WalkthroughWalkthroughThe PR adds durable ChangesExplicit Queue Input Retry
Estimated code review effort: 4 (Complex) | ~45 minutes Possibly related PRs
Suggested reviewers: Sequence Diagram(s)sequenceDiagram
participant PendingInputLane
participant PendingInputStore
participant SessionClient
participant SessionTurn
participant PendingInputAdmissionCoordinator
participant SessionPendingInputStore
PendingInputLane->>PendingInputStore: retryQueueInput(sessionId, itemId)
PendingInputStore->>SessionClient: retryPendingQueueInput(sessionId, itemId)
SessionClient->>SessionTurn: invoke retry route
SessionTurn->>PendingInputAdmissionCoordinator: retryPendingQueueInput(sessionId, itemId)
PendingInputAdmissionCoordinator->>SessionPendingInputStore: retryReleasedQueueInput(itemId)
PendingInputAdmissionCoordinator->>PendingInputAdmissionCoordinator: drain or schedule queue
PendingInputStore->>PendingInputLane: refresh item and clear retrying state
🚥 Pre-merge checks | ✅ 4 | ❌ 1❌ Failed checks (1 warning)
✅ Passed checks (4 passed)
✨ Finishing Touches 💡 1📝 Generate docstrings 💡
🧪 Generate unit tests (beta)
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. Comment |
![coderabbitai[bot]](https://avatars.githubusercontent.com/in/347564?s=60&v=4){kind=small}
Contributor
There was a problem hiding this comment.
Actionable comments posted: 2
🤖 Prompt for all review comments with AI agents
Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.
Inline comments:
In `@src/renderer/src/i18n/ru-RU/chat.json`:
- Line 77: Update the retryRequired translation in the Russian chat localization
to use “Требуется повторная попытка,” clearly indicating that the unsent queue
message must be retried.
In `@test/renderer/stores/pendingInputStore.test.ts`:
- Line 97: Remove the duplicate const retry declaration in the affected test
scope, keeping the single existing createDeferred<{ accepted: boolean; started:
boolean }>() declaration and all references to retry unchanged.
🪄 Autofix
Fix all unresolved CodeRabbit comments on this PR:
- Push a commit to this branch (recommended)
- Create a new PR with the fixes
ℹ️ Review info
⚙️ Run configuration
Configuration used: defaults
Review profile: CHILL
Plan: Pro Plus
Run ID: d28fb894-de3d-44e5-b52b-d2ae20846b5e
📒 Files selected for processing (53)
docs/issues/pending-input-explicit-retry/spec.mdsrc/main/agent/deepchat/harness/deepChatAgentHarness.tssrc/main/agent/deepchat/runtime/pendingInputAdmissionCoordinator.tssrc/main/agent/deepchat/runtime/pendingInputContracts.tssrc/main/agent/deepchat/runtime/pendingInputPump.tssrc/main/agent/manager/deepChatAgentBackend.tssrc/main/agent/manager/sessionHandles.tssrc/main/app/composition.tssrc/main/session/contracts.tssrc/main/session/data/pendingInputStore.tssrc/main/session/data/pendingInputs.tssrc/main/session/routes.tssrc/main/session/turn.tssrc/renderer/api/SessionClient.tssrc/renderer/src/components/chat/PendingInputLane.vuesrc/renderer/src/features/chat-page/ChatPage.vuesrc/renderer/src/features/chat-page/composables/usePendingInputActions.tssrc/renderer/src/i18n/da-DK/chat.jsonsrc/renderer/src/i18n/de-DE/chat.jsonsrc/renderer/src/i18n/en-US/chat.jsonsrc/renderer/src/i18n/es-ES/chat.jsonsrc/renderer/src/i18n/fa-IR/chat.jsonsrc/renderer/src/i18n/fr-FR/chat.jsonsrc/renderer/src/i18n/he-IL/chat.jsonsrc/renderer/src/i18n/id-ID/chat.jsonsrc/renderer/src/i18n/it-IT/chat.jsonsrc/renderer/src/i18n/ja-JP/chat.jsonsrc/renderer/src/i18n/ko-KR/chat.jsonsrc/renderer/src/i18n/ms-MY/chat.jsonsrc/renderer/src/i18n/pl-PL/chat.jsonsrc/renderer/src/i18n/pt-BR/chat.jsonsrc/renderer/src/i18n/ru-RU/chat.jsonsrc/renderer/src/i18n/tr-TR/chat.jsonsrc/renderer/src/i18n/vi-VN/chat.jsonsrc/renderer/src/i18n/zh-CN/chat.jsonsrc/renderer/src/i18n/zh-HK/chat.jsonsrc/renderer/src/i18n/zh-TW/chat.jsonsrc/renderer/src/stores/ui/pendingInput.tssrc/shared/contracts/routes.tssrc/shared/contracts/routes/sessions.routes.tssrc/shared/types/agent-interface.d.tstest/main/agent/deepchat/harness/deepChatAgentHarness.test.tstest/main/agent/deepchat/runtime/pendingInputAdmissionCoordinator.test.tstest/main/agent/deepchat/runtime/pendingInputPump.test.tstest/main/agent/manager/deepChatAgentBackend.test.tstest/main/routes/dispatcher.test.tstest/main/session/data/pendingInputStore.test.tstest/main/session/data/pendingInputs.test.tstest/main/session/data/tables/deepchatPendingInputsTable.test.tstest/main/session/turn.test.tstest/renderer/components/PendingInputLane.test.tstest/renderer/features/chat-page/composables/usePendingInputActions.test.tstest/renderer/stores/pendingInputStore.test.ts
There was a problem hiding this comment.
Pull request overview
Adds durable, explicit retry handling for failed Queue inputs while preserving FIFO, restart, ACP, and attachment behavior.
Changes:
- Introduces
retry_requiredpersistence and retry routing. - Adds localized retry UI and edit-as-retry support.
- Expands regression coverage across runtime, persistence, routes, and renderer.
Reviewed changes
Copilot reviewed 52 out of 53 changed files in this pull request and generated 1 comment.
Show a summary per file
| File | Description |
|---|---|
test/renderer/stores/pendingInputStore.test.ts |
Tests retry deduplication and deferred acceptance. |
test/renderer/features/chat-page/composables/usePendingInputActions.test.ts |
Tests retry actions and payload preservation. |
test/renderer/components/PendingInputLane.test.ts |
Tests retry-required lane controls. |
test/main/session/turn.test.ts |
Tests gated retry delegation and ACP rejection. |
test/main/session/data/tables/deepchatPendingInputsTable.test.ts |
Tests native persistence and FIFO blocking. |
test/main/session/data/pendingInputStore.test.ts |
Tests retry transitions and ordering constraints. |
test/main/session/data/pendingInputs.test.ts |
Tests ownership and restart recovery. |
test/main/routes/dispatcher.test.ts |
Tests retry route dispatch. |
test/main/agent/manager/deepChatAgentBackend.test.ts |
Tests backend retry delegation. |
test/main/agent/deepchat/runtime/pendingInputPump.test.ts |
Tests release, FIFO, and restart behavior. |
test/main/agent/deepchat/runtime/pendingInputAdmissionCoordinator.test.ts |
Tests retry admission and failure recovery. |
test/main/agent/deepchat/harness/deepChatAgentHarness.test.ts |
Updates end-to-end failure-state expectations. |
src/shared/types/agent-interface.d.ts |
Adds the retry_required state. |
src/shared/contracts/routes/sessions.routes.ts |
Defines the typed retry route. |
src/shared/contracts/routes.ts |
Registers the retry route. |
src/renderer/src/stores/ui/pendingInput.ts |
Manages retry state and requests. |
src/renderer/src/i18n/zh-TW/chat.json |
Adds Traditional Chinese retry copy. |
src/renderer/src/i18n/zh-HK/chat.json |
Adds Hong Kong Chinese retry copy. |
src/renderer/src/i18n/zh-CN/chat.json |
Adds Simplified Chinese retry copy. |
src/renderer/src/i18n/vi-VN/chat.json |
Adds Vietnamese retry copy. |
src/renderer/src/i18n/tr-TR/chat.json |
Adds Turkish retry copy. |
src/renderer/src/i18n/ru-RU/chat.json |
Adds Russian retry copy. |
src/renderer/src/i18n/pt-BR/chat.json |
Adds Brazilian Portuguese retry copy. |
src/renderer/src/i18n/pl-PL/chat.json |
Adds Polish retry copy. |
src/renderer/src/i18n/ms-MY/chat.json |
Adds Malay retry copy. |
src/renderer/src/i18n/ko-KR/chat.json |
Adds Korean retry copy. |
src/renderer/src/i18n/ja-JP/chat.json |
Adds Japanese retry copy. |
src/renderer/src/i18n/it-IT/chat.json |
Adds Italian retry copy. |
src/renderer/src/i18n/id-ID/chat.json |
Adds Indonesian retry copy. |
src/renderer/src/i18n/he-IL/chat.json |
Adds Hebrew retry copy. |
src/renderer/src/i18n/fr-FR/chat.json |
Adds French retry copy. |
src/renderer/src/i18n/fa-IR/chat.json |
Adds Persian retry copy. |
src/renderer/src/i18n/es-ES/chat.json |
Adds Spanish retry copy. |
src/renderer/src/i18n/en-US/chat.json |
Adds English retry copy. |
src/renderer/src/i18n/de-DE/chat.json |
Adds German retry copy. |
src/renderer/src/i18n/da-DK/chat.json |
Adds Danish retry copy. |
src/renderer/src/features/chat-page/composables/usePendingInputActions.ts |
Implements renderer retry handling. |
src/renderer/src/features/chat-page/ChatPage.vue |
Connects retry state and events. |
src/renderer/src/components/chat/PendingInputLane.vue |
Displays retry status and controls. |
src/renderer/api/SessionClient.ts |
Exposes the retry client method. |
src/main/session/turn.ts |
Gates retry through session operations. |
src/main/session/routes.ts |
Handles the retry route. |
src/main/session/data/pendingInputStore.ts |
Persists retry state and transitions. |
src/main/session/data/pendingInputs.ts |
Coordinates retry ownership and recovery. |
src/main/session/contracts.ts |
Extends session retry contracts. |
src/main/app/composition.ts |
Wires retry into runtime composition. |
src/main/agent/manager/sessionHandles.ts |
Extends the DeepChat control facet. |
src/main/agent/manager/deepChatAgentBackend.ts |
Delegates backend retries. |
src/main/agent/deepchat/runtime/pendingInputPump.ts |
Enforces retry-aware release and draining. |
src/main/agent/deepchat/runtime/pendingInputContracts.ts |
Adds mutation-specific release disposition. |
src/main/agent/deepchat/runtime/pendingInputAdmissionCoordinator.ts |
Implements retry admission and scheduling. |
src/main/agent/deepchat/harness/deepChatAgentHarness.ts |
Exposes runtime retry operations. |
docs/issues/pending-input-explicit-retry/spec.md |
Documents the design and validation. |
💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.
zerob13
reviewed
Aug 11, 2026
zerob13
left a comment
zerob13
left a comment
Collaborator
There was a problem hiding this comment.
Two actionable state-machine issues remain. The first is reproduced by a failing regression on the current head; the second combines two already-supported paths that are only tested separately.
zerob13
reviewed
Aug 11, 2026
zerob13
left a comment
zerob13
left a comment
Collaborator
There was a problem hiding this comment.
One additional persisted-data compatibility issue:
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
retry_requiredstate for Queue inputs released after a pre-user-fact failure or transcript rollback.Closes #2112.
Root Cause
PR #2023 centralized pending input claim, release, and single-flight draining in
PendingInputPump.When a claimed Queue input failed before its user fact was committed, or after the fact was rolled back, it was released to the FIFO head as an ordinary
pendingrow. The pump intentionally did not replay that row automatically, but the renderer could not distinguish it from a normal draft and exposed no explicit recovery action.PR #2129 added restart recovery and Resume Queue behavior, which made the issue more visible, but did not introduce the original defect.
Changes
retry_requiredtoPendingSessionInputState.claimedtoretry_required.pending.sessions.retryPendingQueueInputroute.acceptedandstartedresults so an accepted retry delayed by a runtime gate is not reported as a failure.attachmentFallbackPolicywhen editing a Queue item.No database migration is required because the pending input state column is unconstrained text.
UI
Before
The failed item remained at the Queue head without explaining why the Queue was blocked or how to continue it.
After
Retry-required rows cannot be reordered or converted to Steer. They can be retried, edited and retried, or removed.
Safety and Compatibility
pending.Validation
pnpm run formatpnpm run i18npnpm run lintpnpm run typecheck:nodepnpm run typecheck:webTwelve native SQLite tests were skipped by the repository harness because the locally installed native module ABI does not match the Node ABI used by Vitest. Equivalent store, FIFO, retry, and restart contracts passed in the non-native suites.
Summary by CodeRabbit
New Features
Bug Fixes