diff --git a/cylc/flow/task_events_mgr.py b/cylc/flow/task_events_mgr.py index 8e3ec3503cc..f1fd5138df0 100644 --- a/cylc/flow/task_events_mgr.py +++ b/cylc/flow/task_events_mgr.py @@ -463,7 +463,8 @@ def process_events(self, schd: 'Scheduler') -> None: if not timer.is_timeout_set(): if timer.next() is None: LOG.warning( - f"{point}/{name}/{submit_num:02d} {key1} failed" + f"{point}/{name}/{submit_num:02d}" + f" handler:{key1[0]} for task event:{key1[1]} failed" ) self.remove_event_timer(id_key) continue @@ -471,13 +472,13 @@ def process_events(self, schd: 'Scheduler') -> None: msg = None if timer.num > 1: msg = ( - f"{key1} failed, " - f"retrying in {timer.delay_timeout_as_str()}" + f"handler:{key1[0]} for task event:{key1[1]} failed," + f" retrying in {timer.delay_timeout_as_str()}" ) elif timer.delay: msg = ( - f"{key1} will run after " - f"{timer.delay_timeout_as_str()}" + f"handler:{key1[0]} for task event:{key1[1]} will" + f" run after {timer.delay_timeout_as_str()}" ) if msg: LOG.debug(f"{point}/{name}/{submit_num:02d} {msg}") diff --git a/tests/flakyfunctional/events/44-timeout.t b/tests/flakyfunctional/events/44-timeout.t index 1b94f7626c5..19a9bc57a62 100755 --- a/tests/flakyfunctional/events/44-timeout.t +++ b/tests/flakyfunctional/events/44-timeout.t @@ -40,7 +40,7 @@ contains_ok 'log' <<__END__ ERROR - [(('event-handler-00', 'started'), 1) cmd] sleeper.sh 1/foo ${LOG_INDENT}[(('event-handler-00', 'started'), 1) ret_code] -9 ${LOG_INDENT}[(('event-handler-00', 'started'), 1) err] killed on timeout (PT10S) -WARNING - 1/foo/01 ('event-handler-00', 'started') failed +WARNING - 1/foo/01 handler:event-handler-00 for task event:started failed __END__ cylc workflow-state "${WORKFLOW_NAME}" >'workflow-state.log' diff --git a/tests/functional/events/10-task-event-job-logs-retrieve.t b/tests/functional/events/10-task-event-job-logs-retrieve.t index 353f7fbe2ab..933a0e89387 100755 --- a/tests/functional/events/10-task-event-job-logs-retrieve.t +++ b/tests/functional/events/10-task-event-job-logs-retrieve.t @@ -50,11 +50,11 @@ cmp_ok 'edited-activities.log' <<'__LOG__' __LOG__ grep -F 'will run after' "${WORKFLOW_RUN_DIR}/log/workflow/log" \ - | cut -d' ' -f 4-10 | sort >"edited-log" + | cut -d' ' -f 4-12 | sort >"edited-log" cmp_ok 'edited-log' <<'__LOG__' -1/t1/01 ('job-logs-retrieve', 'retry') will run after PT5S -1/t1/02 ('job-logs-retrieve', 'retry') will run after PT5S -1/t1/03 ('job-logs-retrieve', 'succeeded') will run after PT5S +1/t1/01 handler:job-logs-retrieve for task event:retry will run after PT5S +1/t1/02 handler:job-logs-retrieve for task event:retry will run after PT5S +1/t1/03 handler:job-logs-retrieve for task event:succeeded will run after PT5S __LOG__ purge