From e25693315e7d05bdb9f0920ee2541b8ced4bd98d Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Sun, 5 Apr 2026 13:16:14 +0900 Subject: [PATCH] fix: stabilize embedded runner transport and channel state --- src/agents/pi-embedded-runner/compact.ts | 5 ++++- src/agents/pi-embedded-runner/run/attempt.ts | 1 + src/gateway/server-channels.ts | 1 + 3 files changed, 6 insertions(+), 1 deletion(-) diff --git a/src/agents/pi-embedded-runner/compact.ts b/src/agents/pi-embedded-runner/compact.ts index d29ccdfb8c4..fe83d1b45ba 100644 --- a/src/agents/pi-embedded-runner/compact.ts +++ b/src/agents/pi-embedded-runner/compact.ts @@ -799,10 +799,13 @@ export async function compactEmbeddedPiSessionDirect( effectiveModel, agentDir, ); - resolveAgentTransportOverride({ + const agentTransportOverride = resolveAgentTransportOverride({ settingsManager, effectiveExtraParams, }); + if (agentTransportOverride && session.agent.transport !== agentTransportOverride) { + session.agent.setTransport(agentTransportOverride); + } try { const prior = await sanitizeSessionHistory({ diff --git a/src/agents/pi-embedded-runner/run/attempt.ts b/src/agents/pi-embedded-runner/run/attempt.ts index d2a9b2c8a60..de72aa344eb 100644 --- a/src/agents/pi-embedded-runner/run/attempt.ts +++ b/src/agents/pi-embedded-runner/run/attempt.ts @@ -981,6 +981,7 @@ export async function runEmbeddedAttempt( `embedded agent transport override: ${activeSession.agent.transport} -> ${agentTransportOverride} ` + `(${params.provider}/${params.modelId})`, ); + activeSession.agent.setTransport(agentTransportOverride); } const cacheObservabilityEnabled = Boolean(cacheTrace) || log.isEnabled("debug"); diff --git a/src/gateway/server-channels.ts b/src/gateway/server-channels.ts index 346ba4ea3ec..b50d610f3b4 100644 --- a/src/gateway/server-channels.ts +++ b/src/gateway/server-channels.ts @@ -78,6 +78,7 @@ function applyDescribedAccountFields( described: ChannelAccountSnapshot | undefined, ) { if (!described) { + next.configured ??= true; return next; } if (typeof described.configured === "boolean") {