diff --git a/cylc/flow/task_events_mgr.py b/cylc/flow/task_events_mgr.py index 646386fee18..4c817f603c3 100644 --- a/cylc/flow/task_events_mgr.py +++ b/cylc/flow/task_events_mgr.py @@ -927,7 +927,7 @@ def _process_message_check( # gets logged by itask state change anyway (and not manual poll) if severity_lvl > DEBUG and flag != self.FLAG_POLLED and message in { self.EVENT_SUBMITTED, self.EVENT_STARTED, self.EVENT_SUCCEEDED, - self.EVENT_SUBMIT_FAILED + self.EVENT_SUBMIT_FAILED, f'{FAIL_MESSAGE_PREFIX}ERR' }: severity_lvl = DEBUG LOG.log(severity_lvl, f"[{itask}] {flag}{message}{timestamp}") @@ -1325,9 +1325,9 @@ def _process_message_failed(self, itask, event_time, message, forced): else: # There is an execution retry lined up. timer = itask.try_timers[TimerFlags.EXECUTION_RETRY] - self._retry_task(itask, timer.timeout) delay_msg = f"retrying in {timer.delay_timeout_as_str()}" - LOG.warning(f"[{itask}] {delay_msg}") + LOG.warning(f'[{itask}] => {TASK_OUTPUT_FAILED} ({delay_msg})') + self._retry_task(itask, timer.timeout) msg = f"{self.JOB_FAILED}, {delay_msg}" self.setup_event_handlers(itask, self.EVENT_RETRY, msg) self._reset_job_timers(itask)