synced with upstream s3 driver
This commit is contained in:
@@ -375,7 +375,6 @@ func (w *writer) open(r io.Reader, closePipeOnError bool) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
if closePipeOnError {
|
if closePipeOnError {
|
||||||
w.pr.CloseWithError(err)
|
w.pr.CloseWithError(err)
|
||||||
w.pr = nil
|
|
||||||
}
|
}
|
||||||
w.err = err
|
w.err = err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user