Revert "add close stream"

This reverts commit 90e214b08fb368e5039f08be0bacc462b5efc790.

apps/app/src/migrations/20211227060705-revision-path-to-page-id-schema-migration--fixed-7549.js

@@ -57,20 +57,8 @@ module.exports = {
     });
 
     pagesStream
-      .on('error', () => {
-        batchStrem.end();
-        migratePagesStream.end();
-      })
       .pipe(batchStrem)
-      .on('error', () => {
-        pagesStream.destroy();
-        migratePagesStream.end();
-      })
-      .pipe(migratePagesStream)
-      .on('error', () => {
-        pagesStream.destroy();
-        batchStrem.destroy();
-      });
+      .pipe(migratePagesStream);
 
     await streamToPromise(migratePagesStream);
 
@@ -120,20 +108,8 @@ module.exports = {
     });
 
     pagesStream
-      .on('error', () => {
-        batchStrem.end();
-        migratePagesStream.end();
-      })
       .pipe(batchStrem)
-      .on('error', () => {
-        pagesStream.destroy();
-        migratePagesStream.end();
-      })
-      .pipe(migratePagesStream)
-      .on('error', () => {
-        pagesStream.destroy();
-        batchStrem.destroy();
-      });
+      .pipe(migratePagesStream);
 
     await streamToPromise(migratePagesStream);