implement pipeline using zmq.proxy

Test using `zmq.proxy` for better load balancing for cases with few distributed items.
Current pipeline using push/pull has issues in this scenario (lowering the hwm helps, but that requires manual tweaking for each case).