fix: condition for bulk resources

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

@@ -14,6 +14,7 @@
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.BulkDependentResource;
 
 @SuppressWarnings("rawtypes")
 public abstract class AbstractWorkflowExecutor<P extends HasMetadata> {
@@ -101,9 +102,15 @@ protected synchronized void handleNodeExecutionFinish(
 
   protected <R> boolean isConditionMet(Optional<Condition<R, P>> condition,
       DependentResource<R, P> dependentResource) {
+    if (condition.isEmpty()) {
+      return true;
+    }
+    var resources = dependentResource instanceof BulkDependentResource
+        ? ((BulkDependentResource) dependentResource).getSecondaryResources(primary, context)
+        : dependentResource.getSecondaryResource(primary, context).orElse(null);
+
     return condition.map(c -> c.isMet(primary,
-        dependentResource.getSecondaryResource(primary, context).orElse(null),
-        context))
+        (R) resources, context))
         .orElse(true);
   }
 }

operator-framework/src/test/java/io/javaoperatorsdk/operator/bulkdependent/BulkDependentWithPreconditionIT.java

@@ -0,0 +1,39 @@
+package io.javaoperatorsdk.operator.bulkdependent;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.javaoperatorsdk.operator.junit.LocallyRunOperatorExtension;
+import io.javaoperatorsdk.operator.sample.bulkdependent.ManagedBulkDependentWithPreconditionReconciler;
+
+import static io.javaoperatorsdk.operator.bulkdependent.BulkDependentTestBase.INITIAL_NUMBER_OF_CONFIG_MAPS;
+import static io.javaoperatorsdk.operator.bulkdependent.BulkDependentTestBase.testResource;
+import static io.javaoperatorsdk.operator.sample.bulkdependent.ConfigMapDeleterBulkDependentResource.LABEL_KEY;
+import static io.javaoperatorsdk.operator.sample.bulkdependent.ConfigMapDeleterBulkDependentResource.LABEL_VALUE;
+import static org.assertj.core.api.Assertions.*;
+import static org.awaitility.Awaitility.await;
+
+class BulkDependentWithPreconditionIT {
+
+  @RegisterExtension
+  LocallyRunOperatorExtension extension =
+      LocallyRunOperatorExtension.builder()
+          .withReconciler(new ManagedBulkDependentWithPreconditionReconciler())
+          .build();
+
+  @Test
+  void handlesBulkDependentWithPrecondition() {
+    var resource = testResource();
+    extension.create(resource);
+
+    await().untilAsserted(() -> {
+      var cms = extension.getKubernetesClient().configMaps().inNamespace(extension.getNamespace())
+          .withLabel(LABEL_KEY, LABEL_VALUE)
+          .list().getItems();
+      assertThat(cms).hasSize(INITIAL_NUMBER_OF_CONFIG_MAPS);
+    });
+  }
+
+
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/bulkdependent/ManagedBulkDependentWithPreconditionReconciler.java

@@ -0,0 +1,29 @@
+package io.javaoperatorsdk.operator.sample.bulkdependent;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
+import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
+import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.Dependent;
+
+@ControllerConfiguration(dependents = @Dependent(reconcilePrecondition = SamplePrecondition.class,
+    type = CRUDConfigMapBulkDependentResource.class))
+public class ManagedBulkDependentWithPreconditionReconciler
+    implements Reconciler<BulkDependentTestCustomResource> {
+
+  private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
+
+  @Override
+  public UpdateControl<BulkDependentTestCustomResource> reconcile(
+      BulkDependentTestCustomResource resource,
+      Context<BulkDependentTestCustomResource> context) throws Exception {
+    numberOfExecutions.incrementAndGet();
+    return UpdateControl.noUpdate();
+  }
+
+  public int getNumberOfExecutions() {
+    return numberOfExecutions.get();
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/bulkdependent/SamplePrecondition.java

@@ -0,0 +1,19 @@
+package io.javaoperatorsdk.operator.sample.bulkdependent;
+
+import java.util.Map;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+
+public class SamplePrecondition
+    implements Condition<Map<String, ConfigMap>, BulkDependentTestCustomResource> {
+
+  public static final String SKIP_RESOURCE_DATA = "skipThis";
+
+  @Override
+  public boolean isMet(BulkDependentTestCustomResource primary, Map<String, ConfigMap> secondary,
+      Context<BulkDependentTestCustomResource> context) {
+    return !SKIP_RESOURCE_DATA.equals(primary.getSpec().getAdditionalData());
+  }
+}