blender/flamenco
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Worker: clearer errors when listener call fails

Browse Source
This commit is contained in:
Sybren A. Stüvel 2022-02-17 13:57:42 +01:00
parent fef0a3cb17
commit ff73f325c8
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/worker/task_executor.go
View File

@ -66,7 +66,7 @@ func (te *TaskExecutor) Run(ctx context.Context, task api.AssignedTask) error {
logger.Info().Str("taskType", task.TaskType).Msg("starting task") logger.Info().Str("taskType", task.TaskType).Msg("starting task")
if err := te.listener.TaskStarted(ctx, task.Uuid); err != nil { 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 { 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 != nil {
if err := te.listener.TaskFailed(ctx, task.Uuid, err.Error()); 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 return err
} }
} }
if err := te.listener.TaskCompleted(ctx, task.Uuid); err != nil { 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 return nil