Removed the extra delete statement from removeTaskFromLimit

Netflix · Nov 30, 2021 · 9e27215 · 9e27215
1 parent d13dd37
commit 9e27215
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java b/...-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java
@@ -628,7 +628,7 @@ public void addTaskToLimit(Task task) {
                     null,
                     null,
                     3,
-                    "Adding taskDefLimit",
+                    "Adding to task_def_limit",
                     "addTaskToLimit"
             );
         } catch (Exception e) {
@@ -645,15 +645,13 @@ public void addTaskToLimit(Task task) {
     public void removeTaskFromLimit(Task task) {
         try {
             recordCassandraDaoRequests("removeTaskFromLimit", task.getTaskType(), task.getWorkflowType());
-            session.execute(
-                    deleteTaskDefLimitStatement.bind(task.getTaskDefName(), UUID.fromString(task.getTaskId())));
             new RetryUtil<>().retryOnException(
                     () -> session.execute(
                             deleteTaskDefLimitStatement.bind(task.getTaskDefName(), UUID.fromString(task.getTaskId()))),
                     null,
                     null,
                     3,
-                    "Deleting taskDefLimit",
+                    "Deleting from task_def_limit",
                     "removeTaskFromLimit"
             );
         } catch (Exception e) {