- Update BulkImports pipelines to process one record
  at a time, instead of operating on a whole collection
  - It is useful when during a transformation of a record
  we need to check if a previously processed record is
  persisted in db or not