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(