progress on dataflow