Piping streams across a cluster of Workers