started new dataflow implementation