Skip to content

Commit c4b657d

Browse files
committed
test(run-engine): thread groupConcurrencyKey into the two direct-Lua ck tests
The gate merge added groupConcurrencyKey=KEYS[13] (and keyPrefix arg) to the base ack and dead-letter commands. Two tests call those Lua commands directly rather than through the public API, so they hard-coded the old key order and misaligned after the merge. Public-API tests were unaffected.
1 parent 565ad2c commit c4b657d

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

‎internal-packages/run-engine/src/run-queue/tests/ckVtime.test.ts‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1529,11 +1529,13 @@ describe("CK virtual-time (SFQ) dequeue", () => {
15291529
ckIndexKey,
15301530
testOptions.keys.queueLengthCounterKeyFromQueue(ghostVariant),
15311531
testOptions.keys.queueRunningCounterKeyFromQueue(ghostVariant),
1532+
testOptions.keys.queueGroupConcurrencyKeyFromQueue(ghostVariant),
15321533
"r-ghost",
15331534
ghostVariant,
15341535
"",
15351536
"0",
1536-
testOptions.keys.toCkWildcard(ghostVariant)
1537+
testOptions.keys.toCkWildcard(ghostVariant),
1538+
"runqueue:test:"
15371539
);
15381540

15391541
// Stranded, which is the state an older instance leaves behind.
@@ -1592,11 +1594,13 @@ describe("CK virtual-time (SFQ) dequeue", () => {
15921594
ckIndexKey,
15931595
testOptions.keys.queueLengthCounterKeyFromQueue(v),
15941596
testOptions.keys.queueRunningCounterKeyFromQueue(v),
1597+
testOptions.keys.queueGroupConcurrencyKeyFromQueue(v),
15951598
ckVtimeKey,
15961599
testOptions.keys.ckVtimeIdleKeyFromQueue(v),
15971600
"r-dlq",
15981601
v,
15991602
testOptions.keys.toCkWildcard(v),
1603+
"runqueue:test:",
16001604
"86400"
16011605
);
16021606

0 commit comments

Comments
 (0)