diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutor.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutor.java index 33ecd12f77..1168d523a9 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutor.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutor.java @@ -169,9 +169,7 @@ public void run() { boolean ready = dependentResourceNode.getReadyPostcondition() .map(rc -> rc.isMet(primary, - context - .getSecondaryResource( - dependentResourceNode.getDependentResource().resourceType()) + dependentResourceNode.getDependentResource().getSecondaryResource(primary, context) .orElse(null), context)) .orElse(true); @@ -212,8 +210,8 @@ public void run() { } boolean deletePostConditionMet = deletePostCondition.map(c -> c.isMet(primary, - context.getSecondaryResource( - dependentResourceNode.getDependentResource().resourceType()).orElse(null), + dependentResourceNode.getDependentResource().getSecondaryResource(primary, context) + .orElse(null), context)).orElse(true); if (deletePostConditionMet) { alreadyVisited.add(dependentResourceNode);