From 04a5f07aea1b514f31e916d3f9fc7cb0e6a58336 Mon Sep 17 00:00:00 2001 From: Ronnie Dutta <61982285+MetRonnie@users.noreply.github.com> Date: Thu, 31 Aug 2023 13:55:27 +0100 Subject: [PATCH] Include severity in delta for task message --- cylc/flow/task_events_mgr.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/cylc/flow/task_events_mgr.py b/cylc/flow/task_events_mgr.py index 852b28f848e..6338f9cfe86 100644 --- 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