@@ -168,8 +168,10 @@ private void submitReconciliationExecution(ResourceID resourceID) {
168
168
private void handleEventMarking (Event event ) {
169
169
if (event instanceof ResourceEvent
170
170
&& ((ResourceEvent ) event ).getAction () == ResourceAction .DELETED ) {
171
+ log .debug ("Marking delete event received for: {}" , event .getRelatedCustomResourceID ());
171
172
eventMarker .markDeleteEventReceived (event );
172
173
} else if (!eventMarker .deleteEventPresent (event .getRelatedCustomResourceID ())) {
174
+ log .debug ("Marking event received for: {}" , event .getRelatedCustomResourceID ());
173
175
eventMarker .markEventReceived (event );
174
176
}
175
177
}
@@ -227,7 +229,13 @@ private void reScheduleExecutionIfInstructed(
227
229
PostExecutionControl <R > postExecutionControl , R customResource ) {
228
230
postExecutionControl
229
231
.getReScheduleDelay ()
230
- .ifPresent (delay -> retryEventSource ().scheduleOnce (customResource , delay ));
232
+ .ifPresent (delay -> {
233
+ if (log .isDebugEnabled ()) {
234
+ log .debug ("ReScheduling event for resource: {} with delay: {}" ,
235
+ ResourceID .fromResource (customResource ), delay );
236
+ }
237
+ retryEventSource ().scheduleOnce (customResource , delay );
238
+ });
231
239
}
232
240
233
241
TimerEventSource <R > retryEventSource () {
@@ -284,6 +292,7 @@ private RetryExecution getOrInitRetryExecution(ExecutionScope<R> executionScope)
284
292
}
285
293
286
294
private void cleanupForDeletedEvent (ResourceID customResourceUid ) {
295
+ log .debug ("Cleaning up for delete event for: {}" , customResourceUid );
287
296
eventMarker .cleanup (customResourceUid );
288
297
metrics .cleanupDoneFor (customResourceUid );
289
298
}
0 commit comments