diff --git a/engine/streams.go b/engine/streams.go
index 697407f1f4..ff7049074a 100644
--- a/engine/streams.go
+++ b/engine/streams.go
@@ -89,7 +89,7 @@ func (o *Output) Write(p []byte) (n int, err error) {
 			firstErr = err
 		}
 	}
-	return len(p), err
+	return len(p), firstErr
 }
 
 // Close unregisters all destinations and waits for all background