private void updateInstanceCount()

in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java [224:239]

• 16 lines of code
• 4 McCabe index (conditional complexity)

  private void updateInstanceCount(int newInstanceCount) throws IOException {
    if (staticConfig.useMinInstances()) {
      if (workloadInfo.workloadType() == WorkloadInfoParser.WorkloadType.SERVICE) {
        cloudRunClientWrapper.updateServiceMinInstances(workloadInfo.name(), newInstanceCount);
      } else {
        cloudRunClientWrapper.updateWorkerPoolMinInstances(workloadInfo.name(), newInstanceCount);
      }
    } else {
      if (workloadInfo.workloadType() == WorkloadInfoParser.WorkloadType.SERVICE) {
        cloudRunClientWrapper.updateServiceManualInstances(workloadInfo.name(), newInstanceCount);
      } else {
        cloudRunClientWrapper.updateWorkerPoolManualInstances(
            workloadInfo.name(), newInstanceCount);
      }
    }
  }