From 09688e6883b694ab275ac97778f7c411a5103c59 Mon Sep 17 00:00:00 2001 From: luke-lombardi <33990301+luke-lombardi@users.noreply.github.com> Date: Fri, 20 Dec 2024 10:35:47 -0500 Subject: [PATCH] log retry failures (#804) --- pkg/task/dispatch.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/pkg/task/dispatch.go b/pkg/task/dispatch.go index b2161935d..e64c91553 100644 --- a/pkg/task/dispatch.go +++ b/pkg/task/dispatch.go @@ -205,11 +205,7 @@ func (d *Dispatcher) RetryTask(ctx context.Context, task types.TaskInterface) er // Hit retry limit, cancel task and resolve if taskMessage.Retries >= taskMessage.Policy.MaxRetries { - - // Don't bother logging it if the retry limit is set to 0, it's just noise - if taskMessage.Policy.MaxRetries != 0 { - log.Info().Str("task_id", taskMessage.TaskId).Str("stub_id", taskMessage.StubId).Msg("dispatcher hit retry limit, not reinserting task") - } + log.Info().Str("task_id", taskMessage.TaskId).Str("stub_id", taskMessage.StubId).Msg("dispatcher hit retry limit, not reinserting task") err = task.Cancel(ctx, types.TaskExceededRetryLimit) if err != nil {