Working data flow

pipes cleaned