ExecutorUtils { public static int getMaxConcurrentRunsOneFlow(final Props azkProps) { return azkProps.getInt(ConfigurationKeys.MAX_CONCURRENT_RUNS_ONEFLOW, Constants.DEFAULT_MAX_ONCURRENT_RUNS_ONEFLOW); } private  ExecutorUtils(); static int getMaxConcurrentRunsOneFlow(final Props azkProps); static Map<Pair<String, String>, Integer> getMaxConcurentRunsPerFlowMap(
      final Props azkProps); static int getMaxConcurrentRunsForFlow(String projectName, String flowName,
      int defaultMaxConcurrentRuns, Map<Pair<String, String>, Integer> maxConcurrentRunsFlowMap);  }
@Test public void testGetMaxConcurrentRunsOneFlow() { Props props = new Props(); assertThat(ExecutorUtils.getMaxConcurrentRunsOneFlow(props)).isEqualTo( Constants.DEFAULT_MAX_ONCURRENT_RUNS_ONEFLOW); props.put(Constants.ConfigurationKeys.MAX_CONCURRENT_RUNS_ONEFLOW, 5); assertThat(ExecutorUtils.getMaxConcurrentRunsOneFlow(props)).isEqualTo( 5); }