ceos/opencode
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(core): compact after tool settlement (#36718)

Browse source
This commit is contained in:
Kit Langton 2026-07-13 15:17:45 -04:00 • committed by GitHub
commit a2f5a0df5d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
packages/core/src/session/runner/llm.ts
View file

@ -543,7 +543,8 @@ const layer = Layer.effect(
needsContinuation = result.needsContinuation needsContinuation = result.needsContinuation
step = result.step + 1 step = result.step + 1
if (needsContinuation) { if (needsContinuation) {
promotion = (yield* SessionPending.compaction(db, input.sessionID)) ? undefined : "steer" yield* runPendingCompaction(input.sessionID)
promotion = "steer"
continue continue
} }
yield* runPendingCompaction(input.sessionID) yield* runPendingCompaction(input.sessionID)

4
packages/core/test/session-runner.test.ts
View file

@ -1614,14 +1614,14 @@ describe("SessionRunnerLLM", () => {
}), }),
) )
it.effect("runs one durable compaction barrier before later steer and queued prompts", () => it.effect("runs one durable compaction barrier after tool settlement and before later inputs", () =>
Effect.gen(function* () { Effect.gen(function* () {
const session = yield* setup const session = yield* setup
currentModel = recoveryModel currentModel = recoveryModel
streamGate = yield* Deferred.make<void>() streamGate = yield* Deferred.make<void>()
streamStarted = yield* Deferred.make<void>() streamStarted = yield* Deferred.make<void>()
responses = [ responses = [
reply.text("Active complete", "text-active"), reply.tool("call-active", "echo", { text: "active" }),
[LLMEvent.textDelta({ id: "summary", text: "durable summary" })], [LLMEvent.textDelta({ id: "summary", text: "durable summary" })],
reply.text("Steer complete", "text-steer"), reply.text("Steer complete", "text-steer"),
reply.text("Queue complete", "text-queue"), reply.text("Queue complete", "text-queue"),