improved logging

Author: csviri

operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/DefaultEventHandler.java

@@ -110,7 +110,10 @@ void eventProcessingFinished(
       ExecutionScope executionScope, PostExecutionControl postExecutionControl) {
     try {
       lock.lock();
-      log.debug("Event processing finished. Scope: {}", executionScope);
+      log.debug(
+          "Event processing finished. Scope: {}, PostExecutionControl: {}",
+          executionScope,
+          postExecutionControl);
       unsetUnderExecution(executionScope.getCustomResourceUid());
 
       if (retry != null && postExecutionControl.exceptionDuringExecution()) {
@@ -143,18 +146,27 @@ private void handleRetryOnException(ExecutionScope executionScope) {
     eventBuffer.putBackEvents(executionScope.getCustomResourceUid(), executionScope.getEvents());
 
     if (newEventsExists) {
+      log.debug("New events exists for for resource id: {}", executionScope.getCustomResourceUid());
       executeBufferedEvents(executionScope.getCustomResourceUid());
       return;
     }
     Optional<Long> nextDelay = execution.nextDelay();
+
     nextDelay.ifPresent(
-        delay ->
-            eventSourceManager
-                .getRetryTimerEventSource()
-                .scheduleOnce(executionScope.getCustomResource(), delay));
+        delay -> {
+          log.debug(
+              "Scheduling timer event for retry with delay:{} for resource: {}",
+              delay,
+              executionScope.getCustomResourceUid());
+          eventSourceManager
+              .getRetryTimerEventSource()
+              .scheduleOnce(executionScope.getCustomResource(), delay);
+        });
   }
 
   private void markSuccessfulExecutionRegardingRetry(ExecutionScope executionScope) {
+    log.debug(
+        "Marking successful execution for resource: {}", executionScope.getCustomResourceUid());
     retryState.remove(executionScope.getCustomResourceUid());
     eventSourceManager
         .getRetryTimerEventSource()

operator-framework/src/test/java/io/javaoperatorsdk/operator/processing/DefaultEventHandlerTest.java

@@ -183,6 +183,8 @@ public void successfulExecutionResetsTheRetry() {
 
     defaultEventHandlerWithRetry.handleEvent(event);
 
+    log.info("Finished successfulExecutionResetsTheRetry");
+
     ArgumentCaptor<ExecutionScope> executionScopeArgumentCaptor =
         ArgumentCaptor.forClass(ExecutionScope.class);
     verify(eventDispatcherMock, timeout(SEPARATE_EXECUTION_TIMEOUT).times(3))