diff --git a/internal/runner/runner.go b/internal/runner/runner.go index 91e80136..8c6c5081 100644 --- a/internal/runner/runner.go +++ b/internal/runner/runner.go @@ -440,7 +440,12 @@ func (r *Runner) normalizeAndQueueInputs(inputs chan taskInput) error { for scanner.Scan() { text := scanner.Text() if text != "" { - r.processInputItem(text, inputs) + for _, item := range strings.Split(text, ",") { + item = strings.TrimSpace(item) + if item != "" { + r.processInputItem(item, inputs) + } + } } } } @@ -449,7 +454,12 @@ func (r *Runner) normalizeAndQueueInputs(inputs chan taskInput) error { for scanner.Scan() { text := scanner.Text() if text != "" { - r.processInputItem(text, inputs) + for _, item := range strings.Split(text, ",") { + item = strings.TrimSpace(item) + if item != "" { + r.processInputItem(item, inputs) + } + } } } }