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' diff --git a/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java b/client/src/main/java/io/dapr/durabletask/TaskOrchestrationExecutor.java index 213c77f2..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.info(() -> 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.info(() -> String.format("shouldRetryBasedOnHandler: %s", shouldRetryBasedOnHandler)); + if (this.handler != null) { + 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())); + // 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