From ff73f325c80320a48ec0712f4874600c0507003d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Thu, 17 Feb 2022 13:57:42 +0100 Subject: [PATCH] Worker: clearer errors when listener call fails --- internal/worker/task_executor.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/worker/task_executor.go b/internal/worker/task_executor.go index 7ce12732..ce0207e8 100644 --- a/internal/worker/task_executor.go +++ b/internal/worker/task_executor.go @@ -66,7 +66,7 @@ func (te *TaskExecutor) Run(ctx context.Context, task api.AssignedTask) error { logger.Info().Str("taskType", task.TaskType).Msg("starting task") if err := te.listener.TaskStarted(ctx, task.Uuid); err != nil { - return fmt.Errorf("error sending notification to manager: %w", err) + return fmt.Errorf("error sending 'task started' notification to manager: %w", err) } for _, cmd := range task.Commands { @@ -83,14 +83,14 @@ func (te *TaskExecutor) Run(ctx context.Context, task api.AssignedTask) error { if err != nil { if err := te.listener.TaskFailed(ctx, task.Uuid, err.Error()); err != nil { - return fmt.Errorf("error sending notification to manager: %w", err) + return fmt.Errorf("error sending 'task failed' notification to manager: %w", err) } return err } } if err := te.listener.TaskCompleted(ctx, task.Uuid); err != nil { - return fmt.Errorf("error sending notification to manager: %w", err) + return fmt.Errorf("error sending 'task completed' notification to manager: %w", err) } return nil