High level python implementation of the pipeline task distribution pattern using ZeroMQ