Merge pull request #27 from TheForbiddenAi/main

Decrease retry log level

Author: cicoyle

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'

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