Skip to content

Commit 08753e0

Browse files
committed
allow setting workerQueueBlockingTimeoutSeconds to 0
1 parent 2247b1f commit 08753e0

File tree

1 file changed

+7
-6
lines changed
  • internal-packages/run-engine/src/batch-queue

1 file changed

+7
-6
lines changed

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

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -134,12 +134,13 @@ export class BatchQueue {
134134
},
135135
// Enable two-stage processing with worker queues for better parallelism (when configured)
136136
// Worker queues provide better concurrency by separating queue selection from message processing
137-
workerQueue: options.workerQueueBlockingTimeoutSeconds
138-
? {
139-
enabled: true,
140-
blockingTimeoutSeconds: options.workerQueueBlockingTimeoutSeconds,
141-
}
142-
: undefined,
137+
workerQueue:
138+
options.workerQueueBlockingTimeoutSeconds !== undefined
139+
? {
140+
enabled: true,
141+
blockingTimeoutSeconds: options.workerQueueBlockingTimeoutSeconds,
142+
}
143+
: undefined,
143144
// Concurrency group based on tenant (environment)
144145
// This limits how many batch items can be processed concurrently per environment
145146
// Items wait in queue until capacity frees up

0 commit comments

Comments
 (0)