diff --git a/src/migrate.ts b/src/migrate.ts index 3b18e9fba..9785b5f31 100644 --- a/src/migrate.ts +++ b/src/migrate.ts @@ -80,7 +80,7 @@ async function main() { const bucket = await getDriveFileBucket(); const readable = bucket.openDownloadStream(file._id); const dest = fs.createWriteStream(temp); - readable.on('data', chunk => dest.write(chunk)); + readable.pipe(dest); readable.on('end', () => { dest.end(); res();