diff --git a/apps/server/src/orchestration/Layers/ProjectionPipeline.test.ts b/apps/server/src/orchestration/Layers/ProjectionPipeline.test.ts index 179d04843c7e..8a3a6bd31ef6 100644 --- a/apps/server/src/orchestration/Layers/ProjectionPipeline.test.ts +++ b/apps/server/src/orchestration/Layers/ProjectionPipeline.test.ts @@ -2497,7 +2497,7 @@ it.layer(BaseTestLayer)("OrchestrationProjectionPipeline", (it) => { }), ); - it.effect("settles a superseded running turn when a new turn becomes active", () => + it.effect("marks a superseded running turn interrupted when a new turn becomes active", () => Effect.gen(function* () { const projectionPipeline = yield* OrchestrationProjectionPipeline; const eventStore = yield* OrchestrationEventStore; @@ -2576,7 +2576,7 @@ it.layer(BaseTestLayer)("OrchestrationProjectionPipeline", (it) => { ORDER BY requested_at `; assert.deepEqual(rows, [ - { turnId: oldTurnId, state: "completed", completedAt: "2026-01-01T00:00:30.000Z" }, + { turnId: oldTurnId, state: "interrupted", completedAt: "2026-01-01T00:00:30.000Z" }, { turnId: newTurnId, state: "running", completedAt: null }, ]); }), diff --git a/apps/server/src/orchestration/Layers/ProjectionPipeline.ts b/apps/server/src/orchestration/Layers/ProjectionPipeline.ts index b5e6cb0cdd54..519ded7c550a 100644 --- a/apps/server/src/orchestration/Layers/ProjectionPipeline.ts +++ b/apps/server/src/orchestration/Layers/ProjectionPipeline.ts @@ -1485,7 +1485,7 @@ const makeOrchestrationProjectionPipeline = Effect.fn("makeOrchestrationProjecti : projectionTurnRepository.upsertByTurnId({ ...turn, turnId: turn.turnId, - state: "completed", + state: "interrupted", completedAt: event.payload.session.updatedAt, }), { concurrency: 1 },