diff --git a/internal/manager/task_state_machine/worker_requeue.go b/internal/manager/task_state_machine/worker_requeue.go index 00101e24..8c23a215 100644 --- a/internal/manager/task_state_machine/worker_requeue.go +++ b/internal/manager/task_state_machine/worker_requeue.go @@ -84,6 +84,7 @@ func (sm *StateMachine) requeueTasksOfWorker( lastErr = err } + // The error is already logged by the log storage. _ = sm.logStorage.WriteTimestamped(logger, task.Job.UUID, task.UUID, task.Activity) }