diff --git a/core/commands/dag/dag.go b/core/commands/dag/dag.go
index a06824461..4eb2283b5 100644
--- a/core/commands/dag/dag.go
+++ b/core/commands/dag/dag.go
@@ -329,7 +329,6 @@ The output of blocks happens in strict DAG-traversal, first-seen, order.
 		}()
 
 		if err := res.Emit(pipeR); err != nil {
-			pipeW.Close() // ignore errors if any
 			return err
 		}