Skip to content

Commit f77b26e

Browse files
committed
wip
Signed-off-by: Attila Mészáros <a_meszaros@apple.com>
1 parent 76be6c0 commit f77b26e

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -380,7 +380,7 @@ private void handleRetryOnException(
380380
ExecutionScope<P> executionScope, Exception exception, boolean errorHandledByReconciler) {
381381
final var state = getOrInitRetryExecution(executionScope);
382382
var resourceID = state.getId();
383-
boolean eventPresent = nextReconciliationImminent(state);
383+
boolean eventPresent = isNextReconciliationImminent(state);
384384
state.markEventReceived();
385385
retryAwareErrorLogging(
386386
state.getRetry(), eventPresent, errorHandledByReconciler, exception, executionScope);
@@ -509,7 +509,7 @@ public synchronized void start() throws OperatorException {
509509
}
510510

511511
public boolean isNextReconciliationImminent(ResourceID resourceID) {
512-
return nextReconciliationImminent(resourceStateManager.getOrCreate(resourceID));
512+
return isNextReconciliationImminent(resourceStateManager.getOrCreate(resourceID));
513513
}
514514

515515
/**
@@ -519,7 +519,7 @@ public boolean isNextReconciliationImminent(ResourceID resourceID) {
519519
* #eventProcessingFinished}) and when it fails (see {@link #handleRetryOnException}), so it has
520520
* to be reported as imminent too.
521521
*/
522-
private boolean nextReconciliationImminent(ResourceState state) {
522+
private boolean isNextReconciliationImminent(ResourceState state) {
523523
return state.eventPresent()
524524
|| (triggerOnAllEvents() && state.isAdditionalEventPresentAfterDeleteEvent());
525525
}

0 commit comments

Comments
 (0)