Sort some event timings inconsistencies

cylc · Feb 11, 2025 · 8c09ef0 · 8c09ef0
1 parent b1714c3
commit 8c09ef0
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/cylc/flow/run_modes/simulation.py b/cylc/flow/run_modes/simulation.py
@@ -93,7 +93,7 @@ def submit_task_job(
         task_job_mgr.get_simulation_job_conf(itask)
     )
     task_job_mgr.task_events_mgr.process_message(
-        itask, INFO, TASK_OUTPUT_SUBMITTED,
+        itask, INFO, TASK_OUTPUT_SUBMITTED, event_time=now[1]
     )
     task_job_mgr.workflow_db_mgr.put_insert_task_jobs(
         itask, {

diff --git a/cylc/flow/run_modes/skip.py b/cylc/flow/run_modes/skip.py
@@ -80,7 +80,9 @@ def submit_task_job(
     )
     task_job_mgr.workflow_db_mgr.put_update_task_state(itask)
     for output in process_outputs(itask, rtconfig):
-        task_job_mgr.task_events_mgr.process_message(itask, INFO, output)
+        task_job_mgr.task_events_mgr.process_message(
+            itask, INFO, output, event_time=now[1]
+        )
 
     return True
 

diff --git a/cylc/flow/task_job_mgr.py b/cylc/flow/task_job_mgr.py
@@ -761,7 +761,8 @@ def _kill_task_job_callback(self, itask, cmd_ctx, line):
             )
         elif itask.state(TASK_STATUS_RUNNING):
             self.task_events_mgr.process_message(
-                itask, CRITICAL, TASK_OUTPUT_FAILED)
+                itask, CRITICAL, TASK_OUTPUT_FAILED, ctx.timestamp
+            )
         else:
             log_lvl = DEBUG
             log_msg = (