addressed code quality feedback

Author: bachuv

exporthistory/src/main/java/com/microsoft/durabletask/exporthistory/ExportJobOrchestrator.java

@@ -151,7 +151,8 @@ private BatchExportResult processBatchWithRetry(
             TaskOrchestrationContext ctx,
             List<String> instanceIds,
             ExportJobConfiguration config) {
-        for (int attempt = 1; attempt <= MAX_RETRY_ATTEMPTS; attempt++) {
+        // Retries until the batch fully succeeds or MAX_RETRY_ATTEMPTS is reached; every path returns from inside.
+        for (int attempt = 1; ; attempt++) {
             List<ExportResult> results = exportBatch(ctx, instanceIds, config);
             List<ExportResult> failedResults = results.stream()
                     .filter(r -> !r.isSuccess())
@@ -161,7 +162,7 @@ private BatchExportResult processBatchWithRetry(
                 return BatchExportResult.succeeded(results.size());
             }
 
-            if (attempt == MAX_RETRY_ATTEMPTS) {
+            if (attempt >= MAX_RETRY_ATTEMPTS) {
                 Instant now = ctx.getCurrentInstant();
                 int finalAttempt = attempt;
                 List<ExportFailure> failures = failedResults.stream()
@@ -179,9 +180,6 @@ private BatchExportResult processBatchWithRetry(
                     MIN_BACKOFF_SECONDS * (int) Math.pow(2, attempt - 1), MAX_BACKOFF_SECONDS);
             ctx.createTimer(Duration.ofSeconds(backoffSeconds)).await();
         }
-
-        // Unreachable: the loop either returns success/failure or retries.
-        return BatchExportResult.succeeded(0);
     }
 
     private List<ExportResult> exportBatch(

exporthistory/src/test/java/com/microsoft/durabletask/exporthistory/ExportHistoryIntegrationTest.java

@@ -6,7 +6,6 @@
 import com.azure.storage.blob.BlobContainerClient;
 import com.azure.storage.blob.BlobServiceClient;
 import com.azure.storage.blob.BlobServiceClientBuilder;
-import com.azure.storage.blob.models.BlobItem;
 import com.azure.storage.blob.models.BlobProperties;
 import com.microsoft.durabletask.DurableTaskClient;
 import com.microsoft.durabletask.DurableTaskGrpcClientBuilder;
@@ -213,11 +212,7 @@ private static long countBlobs(String container) {
         if (!containerClient.exists()) {
             return 0;
         }
-        long count = 0;
-        for (BlobItem ignored : containerClient.listBlobs()) {
-            count++;
-        }
-        return count;
+        return containerClient.listBlobs().stream().count();
     }
 
     private DurableTaskGrpcWorkerBuilder createWorkerBuilder() {