Thread

On second thought, each stage of the pipeline should be writing to a different json file. It needs some work to make it more maintainable..