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

Worker: slight clarification of error message

Browse Source
This commit is contained in:
Sybren A. Stüvel 2022-04-05 16:28:22 +02:00
parent 27e954090c
commit fdab07d987
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/worker/state_awake.go
View File

@ -55,7 +55,12 @@ func (w *Worker) runStateAwake(ctx context.Context) {
// to the Manager. This code only needs to fetch a task and run it.
err := w.taskRunner.Run(ctx, *task)
if err != nil {
log.Warn().Err(err).Interface("task", *task).Msg("error executing task")
select {
case <-ctx.Done():
log.Warn().Err(err).Interface("task", *task).Msg("task aborted due to context being closed")
default:
log.Warn().Err(err).Interface("task", *task).Msg("error executing task")
}
}
// Do some rate limiting. This is mostly useful while developing.