wip

csviri · csviri · commit 5ad74190bd89 · 2022-04-25T13:47:52.000+02:00
diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowCleanupExecutor.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowCleanupExecutor.java
@@ -21,9 +21,15 @@ public WorkflowCleanupExecutor(Workflow<P> workflow, P primary, Context<P> conte
   }
 
 
-  public WorkflowCleanupResult cleanup() {
-
+  public synchronized WorkflowCleanupResult cleanup() {
+    for (DependentResourceNode<?, P> dependentResourceNode : workflow
+        .getTopLevelDependentResources()) {
+      handleCleanup(dependentResourceNode, false);
+    }
     return null;
   }
 
+  private void handleCleanup(DependentResourceNode<?, P> dependentResourceNode, boolean b) {
+
+  }
 }

Original file line number	Diff line number	Diff line change
`@@ -21,9 +21,15 @@ public WorkflowCleanupExecutor(Workflow<P> workflow, P primary, Context<P> conte`
`21`	`21`	`}`
`22`	`22`
`23`	`23`
`24`		`- public WorkflowCleanupResult cleanup() {`
`25`		`-`
	`24`	`+ public synchronized WorkflowCleanupResult cleanup() {`
	`25`	`+ for (DependentResourceNode<?, P> dependentResourceNode : workflow`
	`26`	`+ .getTopLevelDependentResources()) {`
	`27`	`+ handleCleanup(dependentResourceNode, false);`
	`28`	`+ }`
`26`	`29`	`return null;`
`27`	`30`	`}`
`28`	`31`
	`32`	`+ private void handleCleanup(DependentResourceNode<?, P> dependentResourceNode, boolean b) {`
	`33`	`+`
	`34`	`+ }`
`29`	`35`	`}`