fix(runtime): make retained interactive runs durable

bench/src/agent-graphs-improve.mts

@@ -226,7 +226,7 @@ export async function callAuthor(
   const turn = await collectAgentTurn(
     streamAgentTurn(
       { kind: 'executor', factory, profile, agentRunName: profile.name ?? 'agent-graphs-author' },
-      prompt,
+      { prompt },
       timeoutMs === undefined ? {} : { timeoutMs },
     ),
   )

bench/src/atom-mcp-e2e.mts

@@ -103,7 +103,7 @@ async function bridgeChat(opts: {
   const turn = await collectAgentTurn(
     streamAgentTurn(
       { kind: 'executor', factory, profile },
-      opts.messages.map((message) => message.content).join('\n\n'),
+      { prompt: opts.messages.map((message) => message.content).join('\n\n') },
     ),
   )
   if (turn.status !== 'completed') {

bench/src/benchmarks/appworld.ts

@@ -440,7 +440,7 @@ export function appworldToolLoopClient(cfg: {
             const loop = await collectAgentTurn(
               streamAgentTurn(
                 { kind: 'executor', factory, profile },
-                `Task: ${instruction}`,
+                { prompt: `Task: ${instruction}` },
                 { signal },
               ),
             )

bench/src/commit0-gate.mts

@@ -330,7 +330,7 @@ async function runShotLocal(task: BenchTask, attempt: number, cfg: ShotCfg, stee
     const turn = await collectAgentTurn(
       streamAgentTurn(
         { kind: 'executor', factory, profile: workerProfile(cfg, `commit0-local-${attempt}`) },
-        prompt,
+        { prompt },
         cfg.timeoutMs > 0 ? { timeoutMs: cfg.timeoutMs } : {},
       ),
     )

bench/src/humaneval-repair-gate.mts

@@ -89,7 +89,7 @@ async function repairAttempt(cfg: BenchRouterTarget, task: HumanEvalTask, k: num
     },
   })
   const r = await collectAgentTurn(
-    streamAgentTurn({ kind: 'executor', factory, profile }, basePrompt(task)),
+    streamAgentTurn({ kind: 'executor', factory, profile }, { prompt: basePrompt(task) }),
   )
   if (r.status !== 'completed') {
     throw new Error(r.error?.message ?? `repair turn ended with status ${r.status}`)

bench/src/mcp-mount-probe.mts

@@ -70,7 +70,7 @@ async function bridgeChat(messages: Array<{ role: string; content: string }>, mc
   const turn = await collectAgentTurn(
     streamAgentTurn(
       { kind: 'executor', factory, profile },
-      messages.map((message) => message.content).join('\n\n'),
+      { prompt: messages.map((message) => message.content).join('\n\n') },
     ),
   )
   if (turn.status !== 'completed') {

bench/src/quant-arena/quant-loop.mts

@@ -249,7 +249,7 @@ async function profileShot(opts: {
   const turn = await collectAgentTurn(
     streamAgentTurn(
       { kind: 'executor', factory, profile: opts.profile },
-      opts.prompt,
+      { prompt: opts.prompt },
       { timeoutMs: opts.timeoutMs },
     ),
   )

bench/src/router-turn.ts

@@ -7,6 +7,7 @@ import {
   collectAgentTurn,
   createExecutor,
   streamAgentTurn,
+  type AgentTurnInput,
   type CollectedAgentTurn,
   type ToolSpec,
 } from '@tangle-network/agent-runtime/kernel'
@@ -118,10 +119,18 @@ export async function runBenchRouterTurn(
     routerKey: config.routerKey,
     ...(config.tools ? { tools: config.tools } : {}),
   })
+  const turnInput: AgentTurnInput =
+    typeof input === 'string'
+      ? { prompt: input }
+      : {
+          providerOptions: {
+            messages: input.messages.map((message) => ({ ...message })),
+          },
+        }
   const turn = await collectAgentTurn(
     streamAgentTurn(
       { kind: 'executor', factory, profile: config.profile },
-      input,
+      turnInput,
       {
         ...(config.timeoutMs === undefined ? {} : { timeoutMs: config.timeoutMs }),
         ...(config.signal ? { signal: config.signal } : {}),

bench/src/swe-arena/arms.ts

@@ -525,7 +525,7 @@ export async function runSoloArm(spec: SoloArmSpec, ctx: ArmRunContext): Promise
   const turn = await collectAgentTurn(
     streamAgentTurn(
       { kind: 'executor', factory, profile: spec.profile },
-      prompt,
+      { prompt },
       { timeoutMs, ...(ctx.signal ? { signal: ctx.signal } : {}) },
     ),
   )

docs/agent-managed-compute/roadmap.md

@@ -57,10 +57,11 @@ The work is ordered to prove the two-agent atom before adding scale.
 - Extend the existing run record with revisions, ownership generation, commands, provider references, and coordination events.
 - Add durable adapters with conditional writes.
 - Persist dispatch intent before provider creation.
-  Partially done: `startRetainedRun` persists admission after creation and dispatch.
-  `startRetainedRunInEnvironment` applies the same boundary to a fresh session in an existing environment.
-  `recoverRetainedRun` rebuilds a run from the pre-dispatch record.
-  The pre-creation intent record remains open.
+  `startRetainedRun` persists a digest-only intent before creation, then exact
+  environment and dispatch admissions.
+  `startRetainedRunInEnvironment` uses the same retained admissions for a fresh session in an existing environment.
+  `recoverRetainedRun` rebuilds a run from either a pre-create intent or a
+  pre-dispatch environment record.
 - Add a durable provider-command outbox with coordinator generation and command sequence.
 - Rebuild budget reservations and interaction state on restart.
 - Adapt `SpawnJournal`, `ConversationJournal`, and delegation status onto the shared internal record.

docs/api/agent.md

@@ -591,7 +591,7 @@ substantive prompt rewrites, etc.) via this callback.
 
 ##### allowCreateForKinds?
 
-> `optional` **allowCreateForKinds?**: readonly (`"code"` \| `"mcp"` \| `"memory"` \| `"agent-profile"` \| `"rollout-policy"` \| `"knowledge.wiki"` \| `"knowledge.claim"` \| `"knowledge.raw"` \| `"knowledge.stale"` \| `"system-prompt"` \| `"skill"` \| `"tool-doc"` \| `"new-tool"` \| `"hook"` \| `"subagent"` \| `"workflow"` \| `"rag"` \| `"scaffolding"` \| `"output-schema"` \| `"websearch.outdated"` \| `"prior-run-summary"` \| `"cluster"`)[]
+> `optional` **allowCreateForKinds?**: readonly (`"mcp"` \| `"code"` \| `"memory"` \| `"agent-profile"` \| `"rollout-policy"` \| `"knowledge.wiki"` \| `"knowledge.claim"` \| `"knowledge.raw"` \| `"knowledge.stale"` \| `"system-prompt"` \| `"skill"` \| `"tool-doc"` \| `"new-tool"` \| `"hook"` \| `"subagent"` \| `"workflow"` \| `"rag"` \| `"scaffolding"` \| `"output-schema"` \| `"websearch.outdated"` \| `"prior-run-summary"` \| `"cluster"`)[]
 
 When the resolved target doesn't exist, allow the substrate to
 CREATE the file (for `knowledge.wiki`, `new-tool` subjects). Default