Skip to content

Commit 3808790

Browse files
committed
minor improvement scheduling
1 parent a8ff7db commit 3808790

File tree

1 file changed

+1
-1
lines changed
  • operator-framework/src/main/java/com/github/containersolutions/operator/processing

1 file changed

+1
-1
lines changed

operator-framework/src/main/java/com/github/containersolutions/operator/processing/EventScheduler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,9 +102,9 @@ void scheduleEvent(CustomResourceEvent event) {
102102
return;
103103
}
104104
log.debug("Creating scheduled task for event: {}", event);
105+
eventStore.addEventUnderProcessing(event);
105106
executor.schedule(new EventConsumer(event, eventDispatcher, this),
106107
nextBackOff.get(), TimeUnit.MILLISECONDS);
107-
eventStore.addEventUnderProcessing(event);
108108
} finally {
109109
log.debug("Scheduling event finished: {}", event);
110110
lock.unlock();

0 commit comments

Comments
 (0)