Update TaskRunner.java

orkes-io · Jan 22, 2023 · f58319f · f58319f
1 parent 068ef97
commit f58319f
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/main/java/io/orkes/conductor/client/automator/TaskRunner.java b/src/main/java/io/orkes/conductor/client/automator/TaskRunner.java
@@ -314,12 +314,9 @@ private <T, R> R retryOperation(Function<T, R> operation, int count, T input, St
             try {
                 return operation.apply(input);
             } catch (Exception e) {
+                LOGGER.error("Error executing {}", opName, e);
                 index++;
-                try {
-                    Thread.sleep(500L);
-                } catch (InterruptedException ie) {
-                    LOGGER.error("Retry interrupted", ie);
-                }
+                Uninterruptibles.sleepUninterruptibly(500L * (count+1), TimeUnit.MILLISECONDS);
             }
         }
         throw new RuntimeException("Exhausted retries performing " + opName);