From bd257017fc2d811ba6bd1fb42e4c126501cd600a Mon Sep 17 00:00:00 2001 From: csviri Date: Thu, 27 Oct 2022 10:24:33 +0200 Subject: [PATCH] fix: getting secondary in workflows --- .../dependent/workflow/WorkflowReconcileExecutor.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) 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);