From 6451105063aa11aec7def2a57f4d2ff12dad0efc Mon Sep 17 00:00:00 2001 From: root Date: Thu, 16 Jul 2026 20:19:19 +0200 Subject: [PATCH] fix: expose live Kafka admission authority --- internal/cloud/server-agent-chat.test.ts | 1 + internal/cloud/server-code-agent-admission-http.ts | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/cloud/server-agent-chat.test.ts b/internal/cloud/server-agent-chat.test.ts index 92538201..11c851e4 100644 --- a/internal/cloud/server-agent-chat.test.ts +++ b/internal/cloud/server-agent-chat.test.ts @@ -2036,6 +2036,7 @@ test("cloud api AgentRun adapter admits direct live Kafka turns without outbox p const liveAdmission = await waitForTraceEvent(traceStore, traceId, (event) => event.label === "turn:admitted-live-kafka"); assert.equal(liveAdmission.waitingFor, "hwlab-live-kafka-sse"); + assert.match(liveAdmission.message, /without transactional outbox promotion/u); assert.equal(admissionPromotionCalls, 0); await waitForTraceEvent(traceStore, traceId, (event) => event.label === "agentrun:dispatch-intent:admitted"); diff --git a/internal/cloud/server-code-agent-admission-http.ts b/internal/cloud/server-code-agent-admission-http.ts index 3e3146b4..07481b89 100644 --- a/internal/cloud/server-code-agent-admission-http.ts +++ b/internal/cloud/server-code-agent-admission-http.ts @@ -1334,7 +1334,7 @@ async function promoteCodeAgentTurnAdmission({ payload = {}, params = {}, option type: "request", status: "admitted", label: "turn:admitted-live-kafka", - message: "Code Agent turn is live after AgentRun durable dispatch; lifecycle visibility is owned only by hwlab.event.v1.", + message: "Code Agent turn is live after AgentRun durable dispatch; lifecycle visibility is owned by hwlab.event.v1 without transactional outbox promotion.", sessionId: safeSessionId(params.sessionId) || null, runId: payload.agentRun?.runId ?? null, commandId: payload.agentRun?.commandId ?? null,