diff --git a/cylc/flow/task_events_mgr.py b/cylc/flow/task_events_mgr.py
index bee497515a5..c1099c810f4 100644
--- a/cylc/flow/task_events_mgr.py
+++ b/cylc/flow/task_events_mgr.py
@@ -604,7 +604,12 @@ def process_message(
             new_msg = message
 
         msg0 = message.split('/')[0]
+        completed_trigger = itask.state.outputs.set_msg_trg_completion(
+            message=msg0, is_completed=True)
+
         if not quiet:
+            # Add information about task to data-store - if we
+            # haven't already:
             self.data_store_mgr.delta_job_msg(
                 itask.tokens.duplicate(job=str(submit_num)).relative_id,
                 new_msg
@@ -613,8 +618,7 @@ def process_message(
             # (first remove signal: failed/EXIT -> failed)
             self.data_store_mgr.delta_task_output(itask, msg0)
 
-        completed_trigger = itask.state.outputs.set_msg_trg_completion(
-            message=msg0, is_completed=True)
+
 
         # Check the `started` event has not been missed e.g. due to
         # polling delay