Fix for concurrentExecLimit

conductor-oss · May 23, 2024 · 1f2988f · 1f2988f
1 parent 31e2024
commit 1f2988f
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(