From f58319f2bc99a70d9a9a3ef7f42a44e2c9defcc0 Mon Sep 17 00:00:00 2001 From: Viren Baraiya Date: Sun, 22 Jan 2023 13:50:29 -0800 Subject: [PATCH] Update TaskRunner.java --- .../io/orkes/conductor/client/automator/TaskRunner.java | 7 ++----- 1 file changed, 2 insertions(+), 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 index bfeccdf1..489b6866 100644 --- 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 R retryOperation(Function 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);