First pass at distributed_flow