add dataflow to run-dataflow fn