diff --git a/services/filestore/app/coffee/LocalFileWriter.coffee b/services/filestore/app/coffee/LocalFileWriter.coffee index 12d505b05b..2ecb3885df 100644 --- a/services/filestore/app/coffee/LocalFileWriter.coffee +++ b/services/filestore/app/coffee/LocalFileWriter.coffee @@ -14,7 +14,6 @@ module.exports = fsPath = @_getPath(key) logger.log fsPath:fsPath, "writing file locally" writeStream = fs.createWriteStream(fsPath) - stream.pipe writeStream writeStream.on "finish", -> timer.done() logger.log fsPath:fsPath, "finished writing file locally" @@ -25,6 +24,7 @@ module.exports = stream.on "error", (err)-> logger.log err:err, fsPath:fsPath, "problem writing file locally, with read stream" callback err + stream.pipe writeStream deleteFile: (fsPath, callback)-> logger.log fsPath:fsPath, "removing local temp file"