Distillation

Date: Sep 16, 2026

• 🔴 (10:09) User supplied changes to packages/core/src/session/projector.ts, including additional projection logic around SessionEvent.Step.Started, querying a latest record, and creating a synthetic continuation with Prompt.make({ text: "continue" }).
• 🔴 (10:09) User supplied session memory-state update logic that assigns tool.state = castDraft(...) and ignores an event when event.data.assistantMessageID === undefined.
• 🔴 (10:09) User supplied a new 315-line session-recovery implementation that uses EventV2.Service, processes rows in batches via .limit(BATCH_SIZE), and selects pending inputs where SessionInputTable.promoted_seq is null.
• 🔴 (10:09) User supplied recovery processing that conditionally calls execution.wake(row.sessionID) only when a database update reports success: Effect.flatMap((updated) => (updated ? execution.wake(row.sessionID) : Effect.void)).
• 🔴 (10:09) User supplied a scheduled recovery component named "session-recovery".
• 🔴 (10:09) User supplied keyed-runner successor logic calling start(key, successor, false, true) and tracking an optional exit?: Exit.Exit<void, E>.
• 🔴 (10:09) User supplied session-runner execution-state transitions using updateExecution(continuation ? {} : { phase: "ready", assistant_message_id: null }) and, on an uncertain outcome, updateExecution({ phase: "unknown", assistant_message_id: null }).
• 🔴 (10:09) User supplied runner logic retaining the "queue" promotion branch, passing sessionID: session.id, serializing publication with Semaphore.makeUnsafe(1).withPermit, and handling overflow continuation through Effect.die(continueAfterOverflowCompaction(currentStep)).