fix error

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

@@ -58,20 +58,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);
 
@@ -121,20 +109,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);