diff --git a/cmd/exec/exec.go b/cmd/exec/exec.go index 375a8317..27afbf83 100644 --- a/cmd/exec/exec.go +++ b/cmd/exec/exec.go @@ -91,7 +91,13 @@ func Handle(url string) (streamer.Producer, error) { chErr := make(chan error) go func() { - chErr <- cmd.Wait() + err := cmd.Wait() + // unblocking write to channel + select { + case chErr <- err: + default: + log.Trace().Str("url", url).Msg("[exec] close") + } }() select {