Pipeline

class emtools.jobs.Pipeline(debug=False)

Simple implementation of Pipeline class to manage tasks. It will allow to add generators and processors to create new tasks and process them. Internal a Queue classes will be used to connect inputs and outputs.