我在管道中使用for.。of循环，但是循环之后的语句甚至在管道完成执行之前就会执行，即使我在管道中添加await也会发生这种情况

这是我的相关代码

   for(const m of metadata) {
    if(m.path) {
      let dir = `tmp/exports/${exportId}/csv_files_tranformed/${m.type}`;
      let fname = `${dir}/${m.sname}`;
      fs.mkdirSync(dir,{recursive: true}, (err) => {
        if(err) throw err;
      });
      tempm = m;
      await pipeline(
        fs.createReadStream(m.path),
        csv.parse({delimiter: '\t', columns: true}),
        csv.transform((input) => {
            return input;
        }),
        csv.stringify({header: true, delimiter: '\t'}),
        fs.createWriteStream(fname, {encoding: 'utf16le'}),
        (err) => {
          if (err) {
            console.error('Pipeline failed.', err);
          } else {
            console.log('Pipeline succeeded.');
          }
        }
      )
    }
  }

如何确保管道在转到下一个语句之前完全完成。

谢了。