Skip to content

Commit fc50d4d

Browse files
committed
fix(run-engine): the keyless repair clear derives the group key from the environment
The bare queue name is not a full queue key, so the FromQueue producer built a wrong group key for keyless repairs; the env-based producer matches the key the admit paths populate.
1 parent 9a541ef commit fc50d4d

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • internal-packages/run-engine/src/run-queue

‎internal-packages/run-engine/src/run-queue/index.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3160,7 +3160,7 @@ export class RunQueue {
31603160
queueCurrentDequeuedKey,
31613161
envCurrentDequeuedKey,
31623162
messageKey,
3163-
this.keys.queueGroupConcurrencyKeyFromQueue(fullQueue),
3163+
this.keys.queueGroupConcurrencyKey(env, queue),
31643164
messageId,
31653165
this.options.redis.keyPrefix ?? ""
31663166
);

0 commit comments

Comments
 (0)