ZMQ-backed pure-python data pipeline