private Instant getNextUpdateAllowedTime()

in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java [202:213]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  private Instant getNextUpdateAllowedTime(Behavior behavior) throws IOException {
    Duration cooldownSeconds = behavior.cooldownSeconds();
    if (workloadInfo.workloadType() == WorkloadInfoParser.WorkloadType.SERVICE) {
      return cloudRunClientWrapper
          .getServiceLastDeploymentTime(workloadInfo.name())
          .plus(cooldownSeconds);
    } else {
      return cloudRunClientWrapper
          .getWorkerPoolLastDeploymentTime(workloadInfo.name())
          .plus(cooldownSeconds);
    }
  }