Refactored update_dag.py
Prototyped use of message queue.
Prototyped cli message queue tool.