Merge pull request #2589 from pikasTech/fix/workbench-live-admission-diagnostic
Pipelines as Code CI / hwlab-nc01-v03-ci-poll- Success

fix: 暴露 live Kafka admission 权威
This commit is contained in:
Lyon
2026-07-17 02:20:06 +08:00
committed by GitHub
2 changed files with 2 additions and 1 deletions
+1
View File
@@ -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");
@@ -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,