From 1f2988fd44837e2c00fd342d4443a0290e1fb5f4 Mon Sep 17 00:00:00 2001 From: manan164 <1897158+manan164@users.noreply.github.com> Date: Thu, 23 May 2024 19:20:46 +0530 Subject: [PATCH] Fix for concurrentExecLimit --- .../java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java | 2 +- 1 file changed, 1 insertion(+), 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 index b5fbff6a0..c66cf1fae 100644 --- 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 ids = jedisProxy.zrangeByScore(rateLimitKey, 0, score + 1, limit); + Set ids = jedisProxy.zrangeByScore(rateLimitKey, 0, score + 1, Integer.MAX_VALUE); boolean rateLimited = !ids.contains(taskId); if (rateLimited) { LOGGER.info(