### Fixes

- Diagnostics/OTEL: treat normal early model stream cleanup as a completed

model call instead of exporting a misleading `StreamAbandoned` error span.

Thanks @vincentkoc.

- ACP: wait for the configured runtime backend to become healthy before startup

identity reconciliation, avoiding transient acpx warnings during Gateway boot.

Fixes #40566.

expect(JSON.stringify([started.mock.calls, ended.mock.calls])).not.toContain(secretChunk);

});

it("emits error events when stream consumption stops early", async () => {

it("emits completed events when stream consumption stops early", async () => {

async function* stream() {

yield { type: "text", text: "first" };

yield { type: "text", text: "second" };

}

});

expect(events.map((event) => event.type)).toEqual(["model.call.started", "model.call.error"]);

expect(events.map((event) => event.type)).toEqual([

"model.call.started",

"model.call.completed",

]);

expect(events[1]).toMatchObject({

type: "model.call.error",

type: "model.call.completed",

callId: "call-abandoned",

errorCategory: "StreamAbandoned",

durationMs: expect.any(Number),

});

expect(events[1]).not.toHaveProperty("errorCategory");

});

});

} finally {

if (!terminalEmitted) {

await safeReturnIterator(iterator);

emitModelCallError(eventBase, startedAt, { errorCategory: "StreamAbandoned" });

emitModelCallCompleted(eventBase, startedAt);

}

}

}