We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 4dacc44 + b44fc5a commit 7f57f38Copy full SHA for 7f57f38
internal/worker/worker.go
@@ -116,7 +116,9 @@ func (w *Worker[Task, TaskResult]) poller(ctx context.Context) {
116
117
task, err := w.poll(ctx, 30*time.Second)
118
if err != nil {
119
- w.logger.ErrorContext(ctx, "error polling task", "error", err)
+ if !errors.Is(err, context.Canceled) {
120
+ w.logger.ErrorContext(ctx, "error polling task", "error", err)
121
+ }
122
} else if task != nil {
123
w.taskQueue <- task
124
continue // check for new tasks right away
0 commit comments