Skip to content

Commit 4c3d667

Browse files
committed
fix(run-engine): preserve batch queue key namespace
1 parent b63a8ef commit 4c3d667

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

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

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -469,10 +469,8 @@ export class RunEngine {
469469
const batchQueueRedis = options.batchQueue?.redis ?? options.queue.redis;
470470

471471
this.batchQueue = new BatchQueue({
472-
redis: {
473-
keyPrefix: `${batchQueueRedis.keyPrefix ?? ""}batch-queue:`,
474-
...batchQueueRedis,
475-
},
472+
// Preserve the configured namespace so existing batch state remains addressable.
473+
redis: batchQueueRedis,
476474
drr: {
477475
quantum: options.batchQueue?.drr?.quantum ?? 5,
478476
maxDeficit: options.batchQueue?.drr?.maxDeficit ?? 50,

0 commit comments

Comments
 (0)