diff --git a/src/selftest/integration/postgres-kafka-order.ts b/src/selftest/integration/postgres-kafka-order.ts index 7d8fc65..ab58778 100644 --- a/src/selftest/integration/postgres-kafka-order.ts +++ b/src/selftest/integration/postgres-kafka-order.ts @@ -36,8 +36,9 @@ try { const appendB = store.appendEvent(runB.id, "backend_status", { phase: "pg-order-b", orderMarker: "B" }) .finally(() => { appendBSettled = true; }); await delay(250); + const preReleaseClaim = await store.claimKafkaEventOutbox({ owner: "pre-release", leaseMs: 60_000, limit: 1 }); + assert.equal(preReleaseClaim.length, 0, "same-session event B became relay-claimable while event A was still uncommitted"); assert.equal(appendBSettled, false, "same-session event B committed before blocked event A"); - assert.deepEqual(await store.claimKafkaEventOutbox({ owner: "pre-release", leaseMs: 60_000, limit: 1 }), [], "uncommitted event A must not be bypassed by event B"); await gateClient.query("SELECT pg_advisory_unlock($1::bigint)", [gate]); gateHeld = false;