From 8c09ef06b0b73e175f275b6de67541db8b70f6ec Mon Sep 17 00:00:00 2001 From: Ronnie Dutta <61982285+MetRonnie@users.noreply.github.com> Date: Thu, 6 Feb 2025 17:32:17 +0000 Subject: [PATCH] Sort some event timings inconsistencies --- cylc/flow/run_modes/simulation.py | 2 +- cylc/flow/run_modes/skip.py | 4 +++- cylc/flow/task_job_mgr.py | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/cylc/flow/run_modes/simulation.py b/cylc/flow/run_modes/simulation.py index 53ee381925..cb39ed020c 100644 --- 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 index 4e0789ed98..595de4bdcf 100644 --- 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 index 7f72846281..8099bdf2b5 100644 --- 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 = (