Merge pull request #167 from conductor-oss/concrrent_exec_limit

Fix for concurrentExecLimit
conductor-oss · May 26, 2024 · 68e3059 · 68e3059
2 parents 31e2024 + 1f2988f
commit 68e3059
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/redis-persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java b/redis-persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java
@@ -289,7 +289,7 @@ public boolean exceedsLimit(TaskModel task) {
  jedisProxy.zaddnx(rateLimitKey, score, taskId);
  recordRedisDaoRequests("checkTaskRateLimiting", task.getTaskType(), task.getWorkflowType());
 
- Set<String> ids = jedisProxy.zrangeByScore(rateLimitKey, 0, score + 1, limit);
+ Set<String> ids = jedisProxy.zrangeByScore(rateLimitKey, 0, score + 1, Integer.MAX_VALUE);
  boolean rateLimited = !ids.contains(taskId);
  if (rateLimited) {
  LOGGER.info(