dataflow with priority queue works now