Upipe dataflow framework