Working, learning Gustafo, with changes to the filtering that happens in State.py. Pipeline now works to the db from the msg processor, closes #6