Ensure task reservation is released

cschleiden · cschleiden · commit 42307d0b3e6e · 2025-08-07T12:31:53.000-07:00
diff --git a/internal/worker/worker.go b/internal/worker/worker.go
@@ -125,6 +125,7 @@ func (w *Worker[Task, TaskResult]) poller(ctx context.Context) {
 		if err != nil {
 			if !errors.Is(err, context.Canceled) {
 				w.logger.ErrorContext(ctx, "error polling task", "error", err)
+				w.taskQueue.release()
 			}
 		} else if task != nil {
 			if err := w.taskQueue.add(ctx, task); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -125,6 +125,7 @@ func (w *Worker[Task, TaskResult]) poller(ctx context.Context) {`
`125`	`125`	`if err != nil {`
`126`	`126`	`if !errors.Is(err, context.Canceled) {`
`127`	`127`	`w.logger.ErrorContext(ctx, "error polling task", "error", err)`
	`128`	`+ w.taskQueue.release()`
`128`	`129`	`}`
`129`	`130`	`} else if task != nil {`
`130`	`131`	`if err := w.taskQueue.add(ctx, task); err != nil {`