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 = (