Skip to content

Commit fc8cb73

Browse files
committed
add debug log messages for scheduling
1 parent a6177ce commit fc8cb73

File tree

1 file changed

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

1 file changed

+7
-1
lines changed

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

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,8 +114,10 @@ void scheduleEvent(CustomResourceEvent event) {
114114
void eventProcessingFinishedSuccessfully(CustomResourceEvent event) {
115115
try {
116116
lock.lock();
117+
log.debug("Even processing successful for event: {}", event);
117118
eventStore.removeEventUnderProcessing(event.resourceUid());
118119
if (eventStore.containsNotScheduledEvent(event.resourceUid())) {
120+
log.debug("Scheduling not yet scheduled after previous successful processing: {}", event);
119121
scheduleEvent(eventStore.removeEventNotScheduledYet(event.resourceUid()));
120122
}
121123
} finally {
@@ -128,8 +130,12 @@ void eventProcessingFailed(CustomResourceEvent event) {
128130
lock.lock();
129131
eventStore.removeEventUnderProcessing(event.resourceUid());
130132
if (eventStore.containsNotScheduledEvent(event.resourceUid())) {
131-
scheduleEvent(eventStore.removeEventNotScheduledYet(event.resourceUid()));
133+
CustomResourceEvent notScheduledEvent = eventStore.removeEventNotScheduledYet(event.resourceUid());
134+
log.debug("Even processing failed. Scheduling the most recent event. Failed event: {}," +
135+
" Most recent event: {}", event, notScheduledEvent);
136+
scheduleEvent(notScheduledEvent);
132137
} else {
138+
log.debug("Even processing failed. Attempting to re-schedule the event: {}", event);
133139
scheduleEvent(event);
134140
}
135141
} finally {

0 commit comments

Comments
 (0)