public static int getMaxConcurrentRunsForFlow ( String projectName , String flowName , int defaultMaxConcurrentRuns , Map < Pair < String , String > , Integer > maxConcurrentRunsFlowMap ) { return maxConcurrentRunsFlowMap . getOrDefault ( new Pair ( projectName , flowName ) , defaultMaxConcurrentRuns ) ; }
Get the maximum number of concurrent runs for the specified flow using the value in azkaban . concurrent . runs . oneflow . whitelist if explictly specified for the flow and otherwise azkaban . max . concurrent . runs . oneflow or the default .