feat: add MDC to workflow execution (#3188)

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

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

@@ -66,6 +66,15 @@ public static void withMDCForEvent(
     }
   }
 
+  public static void withMDCForResource(HasMetadata resource, Runnable runnable) {
+    try {
+      MDCUtils.addResourceInfo(resource);
+      runnable.run();
+    } finally {
+      MDCUtils.removeResourceInfo();
+    }
+  }
+
   public static void addResourceIDInfo(ResourceID resourceID) {
     if (enabled) {
       MDC.put(NAME, resourceID.getName());

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/NodeExecutor.java

@@ -19,6 +19,7 @@
 import org.slf4j.LoggerFactory;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.processing.MDCUtils;
 
 abstract class NodeExecutor<R, P extends HasMetadata> implements Runnable {
 
@@ -36,19 +37,22 @@ protected NodeExecutor(
 
   @Override
   public void run() {
-    try {
-      doRun(dependentResourceNode);
-
-    } catch (Exception e) {
-      // Exception is required because of Kotlin
-      workflowExecutor.handleExceptionInExecutor(dependentResourceNode, e);
-    } catch (Error e) {
-      // without this user would see no sign about the error
-      log.error("java.lang.Error during execution", e);
-      throw e;
-    } finally {
-      workflowExecutor.handleNodeExecutionFinish(dependentResourceNode);
-    }
+    MDCUtils.withMDCForResource(
+        workflowExecutor.primary,
+        () -> {
+          try {
+            doRun(dependentResourceNode);
+          } catch (Exception e) {
+            // Exception is required because of Kotlin
+            workflowExecutor.handleExceptionInExecutor(dependentResourceNode, e);
+          } catch (Error e) {
+            // without this user would see no sign about the error
+            log.error("java.lang.Error during execution", e);
+            throw e;
+          } finally {
+            workflowExecutor.handleNodeExecutionFinish(dependentResourceNode);
+          }
+        });
   }
 
   protected abstract void doRun(DependentResourceNode<R, P> dependentResourceNode);

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/dependent/workflow/NodeExecutorTest.java

@@ -21,11 +21,10 @@
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
-import static org.junit.jupiter.api.Assertions.*;
-
 class NodeExecutorTest {
 
-  private NodeExecutor errorThrowingNodeExecutor =
+  @SuppressWarnings({"rawtypes", "unchecked"})
+  private final NodeExecutor errorThrowingNodeExecutor =
       new NodeExecutor(null, null) {
         @Override
         protected void doRun(DependentResourceNode dependentResourceNode) {