diff --git a/services/filestore/app/js/PersistorHelper.js b/services/filestore/app/js/PersistorHelper.js index f2d0013915..826412b302 100644 --- a/services/filestore/app/js/PersistorHelper.js +++ b/services/filestore/app/js/PersistorHelper.js @@ -112,6 +112,11 @@ function getReadyPipeline(...streams) { } resolve(lastStream) } + if (err) { + for (const stream of streams) { + stream.destroy() + } + } } pipeline(...streams).catch(handler)