added data import validation workflow to streaming middleware stack