From 6b24421722179b26e54bfa9521b77e117b18f852 Mon Sep 17 00:00:00 2001
From: Alexey Khit <alexey.khit@gmail.com>
Date: Fri, 13 Jan 2023 18:01:01 +0300
Subject: [PATCH] Fix unblocking exec error

---
 cmd/exec/exec.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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 {