Include severity in delta for task message

cylc · Sep 1, 2023 · 04a5f07 · 04a5f07
1 parent 801c1be
commit 04a5f07
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/cylc/flow/task_events_mgr.py b/cylc/flow/task_events_mgr.py
@@ -591,11 +591,10 @@ def process_message(
                 itask, severity, message, event_time, flag, submit_num):
             return None
 
+        new_msg = f'{severity}:{message}'
         # always update the workflow state summary for latest message
         if flag == self.FLAG_POLLED:
-            new_msg = f'{message} {self.FLAG_POLLED}'
-        else:
-            new_msg = message
+            new_msg = f'{new_msg} {self.FLAG_POLLED}'
         self.data_store_mgr.delta_job_msg(
             itask.tokens.duplicate(job=str(submit_num)),
             new_msg