Logging around ProcessorInstance creation

Author: Yaytay

query-engine/docs/query-engine-compose.yml

@@ -59,7 +59,7 @@ services:
     - 14268:14268
 
   query-engine:
-    image: ghcr.io/yaytay/query-engine-design-mode:0.0.45-11-main
+    image: ghcr.io/yaytay/query-engine-design-mode:0.0.45-12-main
     ports:
     - 2000:8080
     volumes:

query-engine/src/main/java/uk/co/spudsoft/query/exec/PipelineExecutorImpl.java

@@ -130,12 +130,18 @@ public List<ProcessorInstance> createProcessors(Vertx vertx, SourceNameTracker s
     for (Processor processor : definition.getProcessors()) {
       Condition condition = processor.getCondition();
       if (condition == null) {
-        result.add(processor.createInstance(vertx, sourceNameTracker, context, processorName(processor.getName(), parentName, "P", index++, processor)));
+        String name = processorName(processor.getName(), parentName, "P", index++, processor);
+        logger.debug("Added {} processor named {} with no condition", processor.getType(), name);
+        result.add(processor.createInstance(vertx, sourceNameTracker, context, name));
       } else {
         ConditionInstance cond = new ConditionInstance(condition.getExpression());
         RequestContext requestContext = RequestContextHandler.getRequestContext(context);
         if (cond.evaluate(requestContext, null)) {
-          result.add(processor.createInstance(vertx, sourceNameTracker, context, processorName(processor.getName(), parentName, "P", index++, processor)));
+          String name = processorName(processor.getName(), parentName, "P", index++, processor);
+          logger.debug("Added {} processor named {} because condition {} met", processor.getType(), name, cond);
+          result.add(processor.createInstance(vertx, sourceNameTracker, context, name));
+        } else {
+          logger.debug("Skipped {} processor {} because condition {} not met", processor.getType(), processor.getName(), cond);
         }
       }
     }

query-engine/src/main/java/uk/co/spudsoft/query/main/Version.java

@@ -34,7 +34,7 @@ public final class Version {
   /**
    * The project version, as set in the Maven pom.xml.
    */
-  public static final String MAVEN_PROJECT_VERSION = "0.0.45-11-main";
+  public static final String MAVEN_PROJECT_VERSION = "0.0.45-12-main";
 
   private Version() {
   }