From 76e26810f70bf39cd53599fa47f133b0118ec8ec Mon Sep 17 00:00:00 2001 From: Mason Date: Thu, 12 Jun 2025 12:38:11 -0400 Subject: [PATCH 1/3] Decrease log level Signed-off-by: Mason --- .../java/io/dapr/durabletask/TaskOrchestrationExecutor.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java b/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java index 213c77f2..3b5c114b 100644 --- a/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java +++ b/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java @@ -1184,18 +1184,18 @@ private boolean shouldRetry() { boolean shouldRetryBasedOnHandler = this.handler != null ? this.handler.handle(retryContext) : true; if (this.policy != null) { - logger.info(() -> String.format("shouldRetryBasedOnPolicy: %s", shouldRetryBasedOnPolicy)); + logger.fine(() -> String.format("shouldRetryBasedOnPolicy: %s", shouldRetryBasedOnPolicy)); } if (this.handler != null) { - logger.info(() -> String.format("shouldRetryBasedOnHandler: %s", shouldRetryBasedOnHandler)); + logger.fine(() -> String.format("shouldRetryBasedOnHandler: %s", shouldRetryBasedOnHandler)); } return shouldRetryBasedOnPolicy && shouldRetryBasedOnHandler; } private boolean shouldRetryBasedOnPolicy() { - logger.warning(() -> String.format("Retry Policy: %d retries out of total %d performed ", this.attemptNumber, this.policy.getMaxNumberOfAttempts())); + logger.fine(() -> String.format("Retry Policy: %d retries out of total %d performed ", this.attemptNumber, this.policy.getMaxNumberOfAttempts())); if (this.attemptNumber >= this.policy.getMaxNumberOfAttempts()) { // Max number of attempts exceeded From 8d17f9f6d3cc007f1f4ce7084abcfd94bbf83200 Mon Sep 17 00:00:00 2001 From: Mason Date: Thu, 12 Jun 2025 12:39:08 -0400 Subject: [PATCH 2/3] Bump version Signed-off-by: Mason --- client/build.gradle | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/build.gradle b/client/build.gradle index 26b3c2ba..b51ce513 100644 --- a/client/build.gradle +++ b/client/build.gradle @@ -10,7 +10,7 @@ plugins { } group 'io.dapr' -version = '1.5.6' +version = '1.5.7' archivesBaseName = 'durabletask-client' def grpcVersion = '1.69.0' From d5cd143bb875a1a56812f550e6f5388472f41cef Mon Sep 17 00:00:00 2001 From: Mason Date: Tue, 17 Jun 2025 11:16:23 -0400 Subject: [PATCH 3/3] Log only when not replaying Signed-off-by: Mason --- .../durabletask/TaskOrchestrationExecutor.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java b/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java index 3b5c114b..b99f12ec 100644 --- a/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java +++ b/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java @@ -1183,19 +1183,25 @@ private boolean shouldRetry() { boolean shouldRetryBasedOnPolicy = this.policy != null ? this.shouldRetryBasedOnPolicy() : true; boolean shouldRetryBasedOnHandler = this.handler != null ? this.handler.handle(retryContext) : true; - if (this.policy != null) { - logger.fine(() -> String.format("shouldRetryBasedOnPolicy: %s", shouldRetryBasedOnPolicy)); - } + // Only log when not replaying, so only the current attempt is logged and not all previous attempts. + if(!this.context.getIsReplaying()) { + if (this.policy != null) { + logger.fine(() -> String.format("shouldRetryBasedOnPolicy: %s", shouldRetryBasedOnPolicy)); + } - if (this.handler != null) { - logger.fine(() -> String.format("shouldRetryBasedOnHandler: %s", shouldRetryBasedOnHandler)); + if (this.handler != null) { + logger.fine(() -> String.format("shouldRetryBasedOnHandler: %s", shouldRetryBasedOnHandler)); + } } return shouldRetryBasedOnPolicy && shouldRetryBasedOnHandler; } private boolean shouldRetryBasedOnPolicy() { - logger.fine(() -> String.format("Retry Policy: %d retries out of total %d performed ", this.attemptNumber, this.policy.getMaxNumberOfAttempts())); + // Only log when not replaying, so only the current attempt is logged and not all previous attempts. + if(!this.context.getIsReplaying()) { + logger.fine(() -> String.format("Retry Policy: %d retries out of total %d performed ", this.attemptNumber, this.policy.getMaxNumberOfAttempts())); + } if (this.attemptNumber >= this.policy.getMaxNumberOfAttempts()) { // Max number of attempts exceeded