summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--internal/pipeline/pipeline.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/pipeline/pipeline.go b/internal/pipeline/pipeline.go
index 5ba0cb4..72d7fd1 100644
--- a/internal/pipeline/pipeline.go
+++ b/internal/pipeline/pipeline.go
@@ -87,8 +87,8 @@ func download(dl chan string, process chan string, conn Pipeliner, dir string, e
if err != nil {
for range dl {
} // consume the rest of the receiving channel so it isn't blocked
- close(process)
errc <- err
+ close(process)
return
}
process <- fn