Trying to build a multi stage data pipeline with pythons multi processing
##DONE :##
established a multi stage pipeline connected via multiprocesssing pipes
###TODO :###
Error Handling, File Checks, Try to convert this into near realtime execution, where the code keeps running and checks and waits for the files to arrive