func (r *fifo) Run(ctx context.Context, sp StageParams) {
	for {
		if !processStageData(ctx, sp, r.executeTask) {
			break
		}
	}
}
Run implements Stage.
package pipeline
import (
	"context"
	"fmt"
)
type fifo struct {
	id   string
	task Task
}
func FIFO(id string, task Task) Stage {
	return &fifo{
		id:   id,
		task: task,
	}
}
func (r *fifo) ID() string {
	return r.id
}