How to continue processing on error

I have a TypeScript program that processes CSV file and for each record a number of awaited operations are performed (DB calls, net lookups, etc, etc)

The questions I have are:

Do I need to worry and resolve backpressure issues or are those handled by promise-streams?
How do I continue processing in case a stream throws an error (e.g. in my case CSV parser throws)
Is there anything in the code flow (see below) regarding usage of promise-streams that I am not doing as intended?

import * as Promise from 'bluebird';
import * as fs from 'fs';
import * as csvParse from 'csv-parse';
const ps = require('promise-streams'); // no typings :(

const csvFile = __dirname + '\\..\\data\\sample.csv';
const csvParserOptions: csvParse.ICsvParseOpts = {
  delimiter: ',',
  rowDelimiter: '\r\n',
  quote: '"',
  columns: true,
  skip_empty_lines: true,
  trim: true,
  auto_parse: false
};

async function processCsvFile(csvFile: string): Promise<void> {
  let recordNum = 1;
  const inStream: fs.ReadStream = fs.createReadStream(csvFile);
  const csvParser: csvParse.CsvParser = csvParse(csvParserOptions);

  return ps.wait(

      inStream
      .pipe(csvParser)
      .pipe(ps.map({concurrent: 1}, (csvRecord: any) => {
        recordNum++;
        console.log(`1) Processing CSV record #: ${recordNum.toLocaleString()} , data: ${JSON.stringify(csvRecord, null, 0)}`);
        return processCsvFileRecord(csvRecord);
      }))

  ).then(() => {
    console.log(`ps.wait() Finished processing!`);
  });

}

async function processCsvFileRecord(csvRecord: any): Promise<void> {
  console.log('2) About to do some other work #1...');
  await dbOp1();
  console.log('3) About to do some other work #2...');
  await dbOp2();
  return;
}

// just a simulation via delay...
async function dbOp1(): Promise<void> {
  return  Promise.delay(1000).then(() => { console.log('2-1) running dbOp1 (1 sec)...'); });
}

async function dbOp2(): Promise<void> {
  return Promise.delay(2000).then(() => { console.log('3-1) running dbOp1 (2 secs)...'); });
}

async function main(): Promise<void> {
    console.log('Begin main()....');
    await processCsvFile(csvFile);
    console.log('The end!');
}

main();

spion / promise-streams

How to continue processing on error #12