Pipelet..remove_source(): handle transaction for fetch using _transactional_fetch()