collection.target.createInput(argv)
    .then((targetStreams) => new Promise((resolve, reject) => {
      _.forEach(targetStreams, (targetStream, index) => {
        targetStream
          .on('error', (error) => {