data store: don't update outputs incrementally

cylc · Oct 11, 2024 · 591632f · 591632f
1 parent b2accfb
commit 591632f
Showing 1 changed file with 19 additions and 5 deletions.
diff --git a/cylc/flow/data_store_mgr.py b/cylc/flow/data_store_mgr.py
@@ -2428,11 +2428,25 @@ def delta_task_output(
         tp_delta = self.updated[TASK_PROXIES].setdefault(
             tp_id, PbTaskProxy(id=tp_id))
         tp_delta.stamp = f'{tp_id}@{update_time}'
-        output = tp_delta.outputs[label]
-        output.label = label
-        output.message = message
-        output.satisfied = outputs.is_message_complete(message)
-        output.time = update_time
+
+        for _label in tproxy.outputs:
+            output = tp_delta.outputs[_label]
+
+            # set the new output
+            if _label == label:
+                output.label = label
+                output.message = message
+                output.satisfied = outputs.is_message_complete(message)
+
+            # ensure all outputs are included in the delta
+            else:
+                _output = tproxy.outputs[_label]
+                output.label = _output.label
+                output.message = _output.message
+                output.satisfied = _output.satisfied
+
+            output.time = update_time
+
         self.updates_pending = True
 
     def delta_task_outputs(self, itask: TaskProxy) -> None: