Distillation

Date: Sep 17, 2026

• 🟡 (10:02) User supplied a partial code excerpt from the Session recovery implementation; visible imports include makeGlobalNode from ../../effect/app-node at line 5, SessionExecution from ../execution at line 11, and SessionExecutionTable at line 17.
• 🟡 (10:02) The recovery acquisition flow constructs const claim = { sessionID, executionID, ownerID } at line 43, attempts a database-backed claim with expires_at: now + leaseDuration, reads the resulting execution state, and invokes restore(...).
• 🟡 (10:02) The recovery flow attaches Effect.onExit(...); its cleanup path queries SessionExecutionTable.phase and can call SessionExecutionClaim.clear(db, claim).
• 🟡 (10:02) The acquisition latch uses Deferred.succeed(acquired, false) on the non-acquired path.
• 🟡 (10:02) settleCancellation is declared as Effect.fnUntraced(function* (claim: SessionExecutionClaim.Claim) { ... }) at line 154. It reads SessionMessageTable.data, handles an assistant message when message?.type === "assistant", preserves or derives message.time.completed, and processes tool-related data.
• 🟡 (10:02) Interrupted Session settlement treats unavailable event infrastructure as fatal via Effect.die("Event service unavailable during interrupted Session settlement").
• 🟡 (10:02) Interrupted provider-step reconciliation records an unknown error with exact payload { type: "unknown", message: "Provider Step outcome unknown after interruption" }.
• 🟡 (10:02) The process-local recovery runner coalesces an already-existing execution by returning Deferred.await(existing); newly started work is scoped and includes claim renewal repeated with Schedule.spaced(Duration.millis(leaseDuration / 3)).