We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ffadd16 commit 4af3dd6Copy full SHA for 4af3dd6
packages/core/src/v3/runEngineWorker/supervisor/consumerPool.ts
@@ -147,7 +147,7 @@ export class RunQueueConsumerPool {
147
// Set initial metrics
148
this.metrics.targetConsumerCount = initialCount;
149
150
- this.scaleToTarget(initialCount);
+ this.addConsumers(initialCount);
151
152
this.logger.log("Started dynamic consumer pool", {
153
initialConsumerCount: this.consumers.size,
0 commit comments