diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/BaseWorkflowResult.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/BaseWorkflowResult.java index f751c88f97..76eeff37dc 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/BaseWorkflowResult.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/BaseWorkflowResult.java @@ -71,13 +71,17 @@ public Optional getDependentConditionResult( } } - protected List listFilteredBy(Function filter) { + public List listFilteredBy(Function filter) { return results.entrySet().stream() .filter(e -> filter.apply(e.getValue())) .map(Map.Entry::getKey) .toList(); } + public Map> getResults() { + return results; + } + @Override public boolean erroredDependentsExist() { if (hasErroredDependents == null) {