Refactored system into observable data pipelines by Martins TalbergsRefactored system into observable data pipelines by Martins Talbergs