Correctly wrap error

Author: cschleiden

backend/redis/taskqueue/queue.go

@@ -137,7 +137,7 @@ func (q *taskQueue[T]) Extend(ctx context.Context, taskID string) error {
 		MinIdle:  0, // Always claim this message
 	}).Result()
 	if err != nil && err != redis.Nil {
-		return errors.Wrap(nil, "could not extend lease")
+		return errors.Wrap(err, "could not extend lease")
 	}
 
 	return nil
@@ -176,7 +176,7 @@ func (q *taskQueue[T]) Complete(ctx context.Context, taskID string) error {
 func (q *taskQueue[T]) Data(ctx context.Context, taskID string) (*TaskItem[T], error) {
 	msg, err := q.rdb.XRange(ctx, q.streamKey, taskID, taskID).Result()
 	if err != nil && err != redis.Nil {
-		return nil, errors.Wrap(nil, "could not find task")
+		return nil, errors.Wrap(err, "could not find task")
 	}
 
 	return msgToTaskItem[T](&msg[0])
@@ -195,7 +195,7 @@ func (q *taskQueue[T]) recover(ctx context.Context, idleTimeout time.Duration) (
 	}).Result()
 
 	if err != nil {
-		return nil, errors.Wrap(nil, "could not recover tasks")
+		return nil, errors.Wrap(err, "could not recover tasks")
 	}
 
 	if len(msgs) == 0 {