Skip to content

Commit 532b480

Browse files
authored
fix: wording (#1619)
1 parent 0c4f9f4 commit 532b480

File tree

1 file changed

+3
-4
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event

1 file changed

+3
-4
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -276,8 +276,7 @@ private void reScheduleExecutionIfInstructed(
276276
.getReScheduleDelay()
277277
.ifPresentOrElse(delay -> {
278278
var resourceID = ResourceID.fromResource(customResource);
279-
log.debug("ReScheduling event for resource: {} with delay: {}",
280-
resourceID, delay);
279+
log.debug("Rescheduling event for resource: {} with delay: {}", resourceID, delay);
281280
retryEventSource().scheduleOnce(resourceID, delay);
282281
}, () -> scheduleExecutionForMaxReconciliationInterval(customResource));
283282
}
@@ -288,8 +287,8 @@ private void scheduleExecutionForMaxReconciliationInterval(R customResource) {
288287
.ifPresent(m -> {
289288
var resourceID = ResourceID.fromResource(customResource);
290289
var delay = m.toMillis();
291-
log.debug("ReScheduling event for resource because for max reconciliation interval: " +
292-
"{} with delay: {}",
290+
log.debug("Rescheduling event for max reconciliation interval for resource: {} : " +
291+
"with delay: {}",
293292
resourceID, delay);
294293
retryEventSource().scheduleOnce(resourceID, delay);
295294
});

0 commit comments

Comments
 (0)