From 7ad6f4821a552dd65628b42834057a3e0fea8233 Mon Sep 17 00:00:00 2001 From: Chris Laprun Date: Tue, 22 Nov 2022 16:30:11 +0100 Subject: [PATCH] fix: wording --- .../operator/processing/event/EventProcessor.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java index e0280796b2..e7a600cf2c 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java @@ -276,8 +276,7 @@ private void reScheduleExecutionIfInstructed( .getReScheduleDelay() .ifPresentOrElse(delay -> { var resourceID = ResourceID.fromResource(customResource); - log.debug("ReScheduling event for resource: {} with delay: {}", - resourceID, delay); + log.debug("Rescheduling event for resource: {} with delay: {}", resourceID, delay); retryEventSource().scheduleOnce(resourceID, delay); }, () -> scheduleExecutionForMaxReconciliationInterval(customResource)); } @@ -288,8 +287,8 @@ private void scheduleExecutionForMaxReconciliationInterval(R customResource) { .ifPresent(m -> { var resourceID = ResourceID.fromResource(customResource); var delay = m.toMillis(); - log.debug("ReScheduling event for resource because for max reconciliation interval: " + - "{} with delay: {}", + log.debug("Rescheduling event for max reconciliation interval for resource: {} : " + + "with delay: {}", resourceID, delay); retryEventSource().scheduleOnce(resourceID, delay); });