Method setConcurrency

packages/node-core/src/utils/queues/rampQueue.ts:52–60

(newConcurrency: number)

  }

  private setConcurrency(newConcurrency: number) {
    const clamped = Math.max(1, Math.min(Math.floor(newConcurrency), this.#maxConcurrency));
    if (clamped > this.concurrency) {
      logger.debug(`${this.name} increased concurrency to ${clamped}`);
    } else if (clamped < this.concurrency) {
      logger.debug(`${this.name} decreased concurrency to ${clamped}`);
    }
    this.concurrency = clamped;
  }

  private adjustConcurrency(data: T): void {
    try {