Moving to store actuators

integratedmodelling · Nov 16, 2024 · cd6b6c0 · cd6b6c0
1 parent 73786e0
commit cd6b6c0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...untime/src/main/java/org/integratedmodelling/klab/services/runtime/ExecutionSequence.java b/...untime/src/main/java/org/integratedmodelling/klab/services/runtime/ExecutionSequence.java
@@ -107,6 +107,7 @@ public boolean run() {
             if (scope.getParallelism() == Parallelism.ONE) {
                 for (var operation : operationGroup) {
                     if (!operation.run()) {
+
                         return false;
                     }
                 }

diff --git a/...s.runtime/src/main/java/org/integratedmodelling/klab/services/runtime/RuntimeService.java b/...s.runtime/src/main/java/org/integratedmodelling/klab/services/runtime/RuntimeService.java
@@ -460,6 +460,7 @@ public Observation runDataflow(Dataflow<Observation> dataflow, ContextScope cont
                     (ServiceContextScope) contextScope, digitalTwin, getComponentRegistry());
             if (!executionSequence.isEmpty()) {
                 if (!executionSequence.run()) {
+                    contextualization.fail(contextScope, dataflow.getTarget());
                     return Observation.empty();
                 }
             }
@@ -474,6 +475,8 @@ public Observation runDataflow(Dataflow<Observation> dataflow, ContextScope cont
             obs.setResolvedCoverage(df.getResolvedCoverage());
         }
 
+        contextualization.success(contextScope, dataflow.getTarget(), dataflow);
+
         return dataflow.getTarget();
     }