Node's Pipeline Bug

main.js

import { pipeline, PassThrough, TransformCallback, Transform } from 'stream/promises';
import { createGunzip } from 'zlib';
import * as csv from 'csv-parser';
import * as S3 from 'aws-sdk/clients/s3';
const s3client = new S3({ maxRetries: 15, httpOptions: { timeout: 15 * 60_000 } });

async function main(bucketName, dataKey) {
  const s3Stream = s3client.getObject({ Bucket: bucketName, Key: dataKey}).createReadStream()
    .on('error', err => { console.error('S3 read error:', err); }); // errors from S3 service
  const unzipStream = createGunzip()
    .on('error', err => { console.error('Unzip error:', err); }) // error unzipping file chuink
  const csvStream = csv({}); // you get the idea
  const myTransformStream = new Transform({
    objectMode: true,
    transform(record, enc, cb) {
      // Makes the record consumable for ddb
      cb(null, record);
    }
  });
  
  try {
    await pipelineAsync(
      s3Stream,
      unzipStream,
      csvStream,
      myTransformStream,
      dynamoDBWriteStream,
      new PassThrough({ objectMode: true })
    );
  } catch (error) {
    console.error(`[Exiting] Caught error processing pipeline for "${dataKey}":`, error);
    throw error;
  }
  console.log(`[Complete] Finished processing pipeline for "${dataKey}"`);
}

main('myBucket', 'myKey');