first flow that can replace broker.py