Distillation

Date: Sep 16, 2026

• 🟡 (15:32) SessionInput.promoteNextQueued in packages/core/src/session/input.ts selects at most one unpromoted "queue" input for a session, excluding inputs already referenced by SessionRecoveryTable.continuation_message_id; it chooses the earliest by ascending SessionInputTable.admitted_seq, returns false when none exists, and otherwise publishes the selected input with the optional commit hook and returns true.
• 🟡 (15:32) SessionInput.promoteExact in packages/core/src/session/input.ts requires a specific messageID belonging to the session with promoted_seq IS NULL and delivery "queue"; if absent, it dies with Pending recovery input not found: ${messageID}.
• 🟡 (15:32) When SessionInput.promoteExact encounters a RecoveryConflict, it updates the matching SessionRecoveryTable row only where execution_id matches, wake_pending = true, and recovery_error IS NULL, setting recovery_error to defect.reason; it then rethrows the defect. Non-RecoveryConflict defects are rethrown unchanged.
• 🟡 (15:32) packages/core/src/session/runner/index.ts defines SessionRunner.Interface.run(input) for one local continuation from already-recorded session history. Input fields are sessionID: SessionSchema.ID, force: boolean, executionID: string, ownerID: string, and optional recoveryInputID?: SessionMessage.ID; the method returns Effect.Effect<void, RunError>.
• 🟡 (15:32) SessionRunner.Interface.run documents that eligible durable work is drained, while explicit runs perform one provider attempt even when no work is eligible.
• 🟡 (15:32) SessionRunner.RunError is the union of LLMError, SessionRunnerModel.Error, MessageDecodeError, ContextSnapshotDecodeError, SystemContext.InitializationBlocked, and ToolOutputStore.Error. The service identifier is @opencode/v2/SessionRunner.