Distillation

Date: Sep 14, 2026

• 🟡 (23:19) packages/core/src/session/execution/local.ts was refactored from a static local coordinator layer to export make = Effect.fnUntraced(function* (input: { readonly run: (sessionID: SessionSchema.ID, force: boolean) => Effect.Effect<void, SessionRunner.RunError> }) { ... }); new imports include and, eq from drizzle-orm, Exit from effect, Database, and SessionExecutionTable.
• 🟡 (23:19) The local session-execution implementation obtains db from Database.Service and assigns each process-local executor a unique ownerID = crypto.randomUUID().
• 🟡 (23:19) packages/core/src/session/execution/local.ts defines clear(sessionID) to delete from SessionExecutionTable only where both session_id = sessionID and owner_id = ownerID; the operation uses .run().pipe(Effect.orDie, Effect.asVoid).
• 🟡 (23:19) The local executor constructs SessionRunCoordinator.make<SessionSchema.ID, SessionRunner.RunError> with an Effect.fnUntraced drain(sessionID, force) callback, routing execution through the injected input.run.
• 🟡 (23:19) packages/core/src/session/recovery.ts obtains EventV2.Service, creates continuationMessageID with SessionMessage.ID.create(), and publishes recovery work with delivery: "queue".
• 🟡 (23:19) Recovery claim cleanup verifies that the claimed SessionExecutionTable row was deleted; if not, it terminates with Effect.die(\Recovery execution claim changed: ${claim.id}`)`.
• 🟡 (23:19) Session recovery is installed through const layer = Layer.effectDiscard(recover()).
• 🟡 (23:19) Session SQL schema evidence includes index message_session_time_created_id_idx on (session_id, time_created, id) and foreign-key references using { onDelete: "cascade" }.