Making decisions in data flow runs