diff --git a/util/progress/multireader.go b/util/progress/multireader.go
index d6d3fb7c79a9..6afcca9feb3a 100644
--- a/util/progress/multireader.go
+++ b/util/progress/multireader.go
@@ -95,6 +95,7 @@ func (mr *MultiReader) Reader(ctx context.Context) Reader {
 		mr.mu.Lock()
 		defer mr.mu.Unlock()
 		delete(mr.writers, w)
+		closeWriter(context.Cause(ctx))
 	}()
 
 	if !mr.initialized {