in internal/preprocess/preprocessing.go [63:72]
func (r *Runner) run(ctx context.Context) error {
defer close(r.out)
for entry := range r.in {
if err := r.processEntry(ctx, entry); err != nil {
continue
}
r.out <- entry
}
return nil
}